Merge pull request #295 from ctria/ignore_label

Added a label to ignore clusters.

controllers/argo_cluster.go

@@ -27,6 +27,7 @@ var (
 const (
 	clusterTakeAlongKey        = "take-along-label.capi-to-argocd."
 	clusterTakenFromClusterKey = "taken-from-cluster-label.capi-to-argocd."
+	clusterIgnoreKey           = "ignore-cluster.capi-to-argocd"
 )
 
 // GetArgoCommonLabels holds a map of labels that reconciled objects must have.
@@ -107,6 +108,18 @@ func extractTakeAlongLabel(key string) (string, error) {
 	return "", nil
 }
 
+// validateClusterIgnoreLabel returns true when the cluster has the clusterIgnoreKey label
+func validateClusterIgnoreLabel(cluster *clusterv1.Cluster) bool {
+	clusterLabels := cluster.Labels
+
+	for k := range clusterLabels {
+		if k == clusterIgnoreKey {
+			return true
+		}
+	}
+	return false
+}
+
 // buildTakeAlongLabels returns a list of valid take-along labels from a cluster
 func buildTakeAlongLabels(cluster *clusterv1.Cluster) (map[string]string, []string) {
 	name := cluster.Name

controllers/capi2argo_reconciler.go

@@ -120,6 +120,12 @@ func (r *Capi2Argo) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Resul
 		log.Info("Failed to get Cluster object", "error", err)
 	}
 
+	// Check if the cluster has the ignore label
+	if validateClusterIgnoreLabel(clusterObject) {
+		log.Info("The cluster has label to be ignored, skipping...")
+		return ctrl.Result{}, nil
+	}
+
 	// Construct ArgoCluster from CapiCluster and CapiSecret.Metadata.
 	argoCluster, err := NewArgoCluster(capiCluster, &capiSecret, clusterObject)
 	if err != nil {