KSPACE-20: Drop the distinction between host & member ToolchainClusters

controllers/toolchaincluster/healthchecker_test.go

@@ -56,7 +56,6 @@ func TestClusterHealthChecks(t *testing.T) {
 		unstable, sec := newToolchainCluster("unstable", "http://unstable.com", withStatus(healthy()))
 		notFound, _ := newToolchainCluster("not-found", "http://not-found.com", withStatus(notOffline(), unhealthy()))
 		stable, _ := newToolchainCluster("stable", "http://cluster.com", withStatus(offline()))
-
 		cl := test.NewFakeClient(t, unstable, notFound, stable, sec)
 		resetCache := setupCachedClusters(t, cl, unstable, notFound, stable)
 		defer resetCache()
@@ -72,7 +71,6 @@ func TestClusterHealthChecks(t *testing.T) {
 
 	t.Run("if no zones nor region is retrieved, then keep the current", func(t *testing.T) {
 		stable, sec := newToolchainCluster("stable", "http://cluster.com", withStatus(offline()))
-
 		cl := test.NewFakeClient(t, stable, sec)
 		resetCache := setupCachedClusters(t, cl, stable)
 		defer resetCache()
@@ -98,7 +96,7 @@ func TestClusterHealthChecks(t *testing.T) {
 }
 
 func setupCachedClusters(t *testing.T, cl *test.FakeClient, clusters ...*toolchainv1alpha1.ToolchainCluster) func() {
-	service := cluster.NewToolchainClusterServiceWithClient(cl, logf.Log, "test-namespace", 0, func(config *rest.Config, options client.Options) (client.Client, error) {
+	service := cluster.NewToolchainClusterServiceWithClient(cl, logf.Log, test.MemberOperatorNs, 0, func(config *rest.Config, options client.Options) (client.Client, error) {
 		// make sure that insecure is false to make Gock mocking working properly
 		config.Insecure = false
 		return client.New(config, options)
@@ -124,7 +122,7 @@ func withStatus(conditions ...toolchainv1alpha1.ToolchainClusterCondition) toolc
 }
 
 func newToolchainCluster(name, apiEndpoint string, status toolchainv1alpha1.ToolchainClusterStatus) (*toolchainv1alpha1.ToolchainCluster, *corev1.Secret) {
-	toolchainCluster, secret := test.NewToolchainClusterWithEndpoint(name, "secret", apiEndpoint, status, map[string]string{})
+	toolchainCluster, secret := test.NewToolchainClusterWithEndpoint(name, "test-namespace", "secret", apiEndpoint, status, map[string]string{"namespace": "test-namespace"})
 	return toolchainCluster, secret
 }
 

controllers/toolchaincluster/toolchaincluster_controller.go

@@ -61,33 +61,5 @@ func (r *Reconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.
 		return reconcile.Result{}, err
 	}
 
-	// add toolchaincluster role label if not present
-	reqLogger.Info("adding cluster role label based on type")
-	if err := r.addToolchainClusterRoleLabelFromType(ctx, toolchainCluster); err != nil {
-		return reconcile.Result{}, err
-	}
-
 	return reconcile.Result{}, r.clusterCacheService.AddOrUpdateToolchainCluster(toolchainCluster)
 }
-
-func (r *Reconciler) addToolchainClusterRoleLabelFromType(ctx context.Context, toolchainCluster *toolchainv1alpha1.ToolchainCluster) error {
-	logger := log.FromContext(ctx)
-
-	if clusterType, found := toolchainCluster.Labels[cluster.LabelType]; !found {
-		logger.Info("cluster `type` label not found, unable to add toolchain cluster role label from type")
-		return nil
-	} else if clusterType != string(cluster.Member) {
-		logger.Info("cluster `type` is not member, skipping cluster role label setting")
-		return nil
-	}
-	clusterRoleLabel := cluster.RoleLabel(cluster.Tenant)
-	if _, exists := toolchainCluster.Labels[clusterRoleLabel]; !exists {
-		logger.Info("setting cluster role label for toolchaincluster", clusterRoleLabel, toolchainCluster.Name)
-		// We use only the label key, the value can remain empty.
-		toolchainCluster.Labels[clusterRoleLabel] = ""
-		if err := r.client.Update(ctx, toolchainCluster); err != nil {
-			return err
-		}
-	}
-	return nil
-}

pkg/cluster/cache.go

@@ -24,8 +24,6 @@ type Config struct {
 	// APIEndpoint is the API endpoint of the corresponding ToolchainCluster. This can be a hostname,
 	// hostname:port, IP or IP:port.
 	APIEndpoint string
-	// Type is a type of the cluster (either host or member)
-	Type Type
 	// OperatorNamespace is a name of a namespace (in the cluster) the operator is running in
 	OperatorNamespace string
 	// OwnerClusterName keeps the name of the cluster the ToolchainCluster resource is created in
@@ -81,23 +79,21 @@ var Ready Condition = func(cluster *CachedToolchainCluster) bool {
 	return IsReady(cluster.ClusterStatus)
 }
 
-func (c *toolchainClusterClients) getCachedToolchainClustersByType(clusterType Type, conditions ...Condition) []*CachedToolchainCluster {
+func (c *toolchainClusterClients) getCachedToolchainClusters(conditions ...Condition) []*CachedToolchainCluster {
 	c.RLock()
 	defer c.RUnlock()
-	return Filter(clusterType, c.clusters, conditions...)
+	return Filter(c.clusters, conditions...)
 }
-func Filter(clusterType Type, clusters map[string]*CachedToolchainCluster, conditions ...Condition) []*CachedToolchainCluster {
+func Filter(clusters map[string]*CachedToolchainCluster, conditions ...Condition) []*CachedToolchainCluster {
 	filteredClusters := make([]*CachedToolchainCluster, 0, len(clusters))
 clusters:
 	for _, cluster := range clusters {
-		if cluster.Type == clusterType {
-			for _, match := range conditions {
-				if !match(cluster) {
-					continue clusters
-				}
+		for _, match := range conditions {
+			if !match(cluster) {
+				continue clusters
 			}
-			filteredClusters = append(filteredClusters, cluster)
 		}
+		filteredClusters = append(filteredClusters, cluster)
 	}
 	return filteredClusters
 }
@@ -117,12 +113,12 @@ var HostCluster GetHostClusterFunc = GetHostCluster
 // GetHostCluster returns the kube client for the host cluster from the cache of the clusters
 // and info if such a client exists
 func GetHostCluster() (*CachedToolchainCluster, bool) {
-	clusters := clusterCache.getCachedToolchainClustersByType(Host)
+	clusters := clusterCache.getCachedToolchainClusters()
 	if len(clusters) == 0 {
 		if clusterCache.refreshCache != nil {
 			clusterCache.refreshCache()
 		}
-		clusters = clusterCache.getCachedToolchainClustersByType(Host)
+		clusters = clusterCache.getCachedToolchainClusters()
 		if len(clusters) == 0 {
 			return nil, false
 		}
@@ -138,24 +134,16 @@ var MemberClusters GetMemberClustersFunc = GetMemberClusters
 
 // GetMemberClusters returns the kube clients for the host clusters from the cache of the clusters
 func GetMemberClusters(conditions ...Condition) []*CachedToolchainCluster {
-	clusters := clusterCache.getCachedToolchainClustersByType(Member, conditions...)
+	clusters := clusterCache.getCachedToolchainClusters(conditions...)
 	if len(clusters) == 0 {
 		if clusterCache.refreshCache != nil {
 			clusterCache.refreshCache()
 		}
-		clusters = clusterCache.getCachedToolchainClustersByType(Member, conditions...)
+		clusters = clusterCache.getCachedToolchainClusters(conditions...)
 	}
 	return clusters
 }
 
-// Type is a cluster type (either host or member)
-type Type string
-
-const (
-	Member Type = "member"
-	Host   Type = "host"
-)
-
 // Role defines the role of the cluster.
 // Each type of cluster can have multiple roles (tenant for specific APIs, user workloads, others ... )
 type Role string