feat: anywhere provider

internal/castai/types.go

@@ -41,6 +41,11 @@ type OpenshiftParams struct {
 	InternalID  string `json:"internalId"`
 }
 
+type AnywhereParams struct {
+	ClusterName           string    `json:"clusterName"`
+	KubeSystemNamespaceID uuid.UUID `json:"kubeSystemNamespaceId"`
+}
+
 type RegisterClusterRequest struct {
 	ID        uuid.UUID        `json:"id"`
 	Name      string           `json:"name"`
@@ -49,6 +54,7 @@ type RegisterClusterRequest struct {
 	KOPS      *KOPSParams      `json:"kops"`
 	AKS       *AKSParams       `json:"aks"`
 	Openshift *OpenshiftParams `json:"openshift"`
+	Anywhere  *AnywhereParams  `json:"anywhere"`
 }
 
 type Cluster struct {

internal/config/config.go

@@ -27,6 +27,7 @@ type Config struct {
 	KOPS      *KOPS      `mapstructure:"kops"`
 	AKS       *AKS       `mapstructure:"aks"`
 	OpenShift *OpenShift `mapstructure:"openshift"`
+	Anywhere  *Anywhere  `mapstructure:"anywhere"`
 
 	Static      *Static     `mapstructure:"static"`
 	Controller  *Controller `mapstructure:"controller"`
@@ -109,6 +110,10 @@ type Static struct {
 	ClusterID string `mapstructure:"cluster_id"`
 }
 
+type Anywhere struct {
+	ClusterName string `mapstructure:"cluster_name"`
+}
+
 type Controller struct {
 	Interval                       time.Duration `mapstructure:"interval"`
 	MemoryPressureInterval         time.Duration `mapstructure:"memory_pressure_interval"`

internal/services/discovery/discovery.go

@@ -18,6 +18,10 @@ import (
 )
 
 type Service interface {
+	// GetCSP discovers the cluster cloud service provider (CSP) by listing the cluster nodes and inspecting their labels.
+	// CSP is retrieved by parsing the Node.Spec.ProviderID property.
+	GetCSP(ctx context.Context) (csp cloud.Cloud, reterr error)
+
 	// GetCSPAndRegion discovers the cluster cloud service provider (CSP) and the region the cluster is deployed in by
 	// listing the cluster nodes and inspecting their labels. CSP is retrieved by parsing the Node.Spec.ProviderID property.
 	// Whereas the region is read from the well-known node region labels.
@@ -26,6 +30,9 @@ type Service interface {
 	// GetClusterID retrieves the cluster ID by reading the UID of the kube-system namespace.
 	GetClusterID(ctx context.Context) (*uuid.UUID, error)
 
+	// GetKubeSystemNamespaceId retrieves the UID of the kube-system namespace.
+	GetKubeSystemNamespaceId(ctx context.Context) (*uuid.UUID, error)
+
 	// GetKOPSClusterNameAndStateStore discovers the cluster name and kOps state store bucket from the kube-system namespace
 	// annotation. kOps annotates the kube-system namespace with annotations such as this:
 	// * addons.k8s.io/core.addons.k8s.io: '{"version":"1.4.0","channel":"s3://bucket/cluster-name/addons/bootstrap-channel.yaml","manifestHash":"hash"}'
@@ -57,22 +64,30 @@ func New(clientset kubernetes.Interface, dyno dynamic.Interface) *ServiceImpl {
 	}
 }
 
+func (s *ServiceImpl) GetCSP(ctx context.Context) (cloud.Cloud, error) {
+	return s.getCSP(ctx, "")
+}
+
 func (s *ServiceImpl) GetCSPAndRegion(ctx context.Context) (csp cloud.Cloud, region string, reterr error) {
 	return s.getCSPAndRegion(ctx, "")
 }
 
 func (s *ServiceImpl) GetClusterID(ctx context.Context) (*uuid.UUID, error) {
+	return s.GetKubeSystemNamespaceId(ctx)
+}
+
+func (s *ServiceImpl) GetKubeSystemNamespaceId(ctx context.Context) (*uuid.UUID, error) {
 	ns, err := s.getKubeSystemNamespace(ctx)
 	if err != nil {
 		return nil, err
 	}
 
-	clusterID, err := uuid.Parse(string(ns.UID))
+	namespaceID, err := uuid.Parse(string(ns.UID))
 	if err != nil {
 		return nil, fmt.Errorf("parsing namespace %q uid: %w", metav1.NamespaceSystem, err)
 	}
 
-	return &clusterID, nil
+	return &namespaceID, nil
 }
 
 func (s *ServiceImpl) getKubeSystemNamespace(ctx context.Context) (*v1.Namespace, error) {
@@ -93,10 +108,36 @@ func (s *ServiceImpl) getKubeSystemNamespace(ctx context.Context) (*v1.Namespace
 	return ns, nil
 }
 
+func (s *ServiceImpl) getCSP(ctx context.Context, next string) (cloud.Cloud, error) {
+	nodes, err := s.listNodes(ctx, next)
+	if err != nil {
+		return "", err
+	}
+
+	for i := range nodes.Items {
+		node := &nodes.Items[i]
+
+		if !isNodeReady(node) {
+			continue
+		}
+
+		nodeCSP, ok := getNodeCSP(node)
+		if ok {
+			return nodeCSP, nil
+		}
+	}
+
+	if nodes.Continue != "" {
+		return s.getCSP(ctx, nodes.Continue)
+	}
+
+	return "", fmt.Errorf("failed to discover csp")
+}
+
 func (s *ServiceImpl) getCSPAndRegion(ctx context.Context, next string) (csp cloud.Cloud, region string, reterr error) {
-	nodes, err := s.clientset.CoreV1().Nodes().List(ctx, metav1.ListOptions{Limit: 10, Continue: next})
+	nodes, err := s.listNodes(ctx, next)
 	if err != nil {
-		return "", "", fmt.Errorf("listing nodes: %w", err)
+		return "", "", err
 	}
 
 	for i := range nodes.Items {
@@ -106,7 +147,7 @@ func (s *ServiceImpl) getCSPAndRegion(ctx context.Context, next string) (csp clo
 			continue
 		}
 
-		nodeCSP, ok := getCSP(node)
+		nodeCSP, ok := getNodeCSP(node)
 		if ok {
 			csp = nodeCSP
 		}
@@ -128,6 +169,15 @@ func (s *ServiceImpl) getCSPAndRegion(ctx context.Context, next string) (csp clo
 	return "", "", fmt.Errorf("failed discovering properties: csp=%q, region=%q", csp, region)
 }
 
+func (s *ServiceImpl) listNodes(ctx context.Context, next string) (*v1.NodeList, error) {
+	nodes, err := s.clientset.CoreV1().Nodes().List(ctx, metav1.ListOptions{Limit: 10, Continue: next})
+	if err != nil {
+		return nil, fmt.Errorf("listing nodes: %w", err)
+	}
+
+	return nodes, nil
+}
+
 func isNodeReady(n *v1.Node) bool {
 	for _, cond := range n.Status.Conditions {
 		if cond.Type == v1.NodeReady && cond.Status == v1.ConditionTrue {
@@ -150,7 +200,7 @@ func getRegion(n *v1.Node) (string, bool) {
 	return "", false
 }
 
-func getCSP(n *v1.Node) (cloud.Cloud, bool) {
+func getNodeCSP(n *v1.Node) (cloud.Cloud, bool) {
 	providerID := n.Spec.ProviderID
 
 	if strings.HasPrefix(providerID, "gce://") {