Add exlude namespace predicate

controllers/config/clientconfig_controller.go

@@ -24,6 +24,7 @@ import (
 	configapi "github.com/k8ssandra/k8ssandra-operator/apis/config/v1beta1"
 	k8ssandraapi "github.com/k8ssandra/k8ssandra-operator/apis/k8ssandra/v1alpha1"
 	"github.com/k8ssandra/k8ssandra-operator/pkg/clientcache"
+	custompredicate "github.com/k8ssandra/k8ssandra-operator/pkg/predicate"
 	"github.com/k8ssandra/k8ssandra-operator/pkg/utils"
 )
 
@@ -104,7 +105,7 @@ func (r *ClientConfigReconciler) SetupWithManager(mgr ctrl.Manager, cancelFunc c
 	}
 
 	cb := ctrl.NewControllerManagedBy(mgr).
-		For(&configapi.ClientConfig{}, builder.WithPredicates(predicate.GenerationChangedPredicate{})).
+		For(&configapi.ClientConfig{}, builder.WithPredicates(predicate.GenerationChangedPredicate{}, custompredicate.NewExcludeNamespacePredicate())).
 		Watches(&source.Kind{Type: &corev1.Secret{}}, handler.EnqueueRequestsFromMapFunc(toMatchingClientConfig))
 
 	return cb.Complete(r)

controllers/control/k8ssandratask_controller.go

@@ -49,6 +49,7 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/log"
 
 	api "github.com/k8ssandra/k8ssandra-operator/apis/control/v1alpha1"
+	custompredicate "github.com/k8ssandra/k8ssandra-operator/pkg/predicate"
 )
 
 const (
@@ -352,7 +353,7 @@ func (r *K8ssandraTaskReconciler) reportInvalidSpec(
 // SetupWithManager sets up the controller with the Manager.
 func (r *K8ssandraTaskReconciler) SetupWithManager(mgr ctrl.Manager, clusters []cluster.Cluster) error {
 	cb := ctrl.NewControllerManagedBy(mgr).
-		For(&api.K8ssandraTask{}, builder.WithPredicates(predicate.GenerationChangedPredicate{}))
+		For(&api.K8ssandraTask{}, builder.WithPredicates(predicate.GenerationChangedPredicate{}, custompredicate.NewExcludeNamespacePredicate()))
 
 	kTaskLabelFilter := func(mapObj client.Object) []reconcile.Request {
 		requests := make([]reconcile.Request, 0)

controllers/k8ssandra/k8ssandracluster_controller.go

@@ -18,6 +18,7 @@ package k8ssandra
 
 import (
 	"context"
+	custompredicate "github.com/k8ssandra/k8ssandra-operator/pkg/predicate"
 	v1 "k8s.io/api/core/v1"
 
 	"github.com/go-logr/logr"
@@ -180,7 +181,7 @@ func (r *K8ssandraClusterReconciler) afterCassandraReconciled(ctx context.Contex
 // SetupWithManager sets up the controller with the Manager.
 func (r *K8ssandraClusterReconciler) SetupWithManager(mgr ctrl.Manager, clusters []cluster.Cluster) error {
 	cb := ctrl.NewControllerManagedBy(mgr).
-		For(&api.K8ssandraCluster{}, builder.WithPredicates(predicate.GenerationChangedPredicate{})) // No generation changed predicate here?
+		For(&api.K8ssandraCluster{}, builder.WithPredicates(predicate.GenerationChangedPredicate{}, custompredicate.NewExcludeNamespacePredicate())) // No generation changed predicate here?
 
 	clusterLabelFilter := func(mapObj client.Object) []reconcile.Request {
 		requests := make([]reconcile.Request, 0)

controllers/medusa/medusabackupjob_controller.go

@@ -19,6 +19,7 @@ package medusa
 import (
 	"context"
 	"fmt"
+	custompredicate "github.com/k8ssandra/k8ssandra-operator/pkg/predicate"
 	"net"
 	"sync"
 
@@ -268,6 +269,6 @@ func medusaBackupFinished(backup *medusav1alpha1.MedusaBackupJob) bool {
 // SetupWithManager sets up the controller with the Manager.
 func (r *MedusaBackupJobReconciler) SetupWithManager(mgr ctrl.Manager) error {
 	return ctrl.NewControllerManagedBy(mgr).
-		For(&medusav1alpha1.MedusaBackupJob{}, builder.WithPredicates(predicate.GenerationChangedPredicate{})).
+		For(&medusav1alpha1.MedusaBackupJob{}, builder.WithPredicates(predicate.GenerationChangedPredicate{}, custompredicate.NewExcludeNamespacePredicate())).
 		Complete(r)
 }

controllers/medusa/medusabackupschedule_controller.go

@@ -19,6 +19,7 @@
 import (
 	"context"
 	"fmt"
+	custompredicate "github.com/k8ssandra/k8ssandra-operator/pkg/predicate"
 	"time"
 
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -137,6 +138,6 @@
 // SetupWithManager sets up the controller with the Manager.
 func (r *MedusaBackupScheduleReconciler) SetupWithManager(mgr ctrl.Manager) error {
 	return ctrl.NewControllerManagedBy(mgr).
-		For(&medusav1alpha1.MedusaBackupSchedule{}, builder.WithPredicates(predicate.GenerationChangedPredicate{})).
+		For(&medusav1alpha1.MedusaBackupSchedule{}, builder.WithPredicates(predicate.GenerationChangedPredicate{}, custompredicate.NewExcludeNamespacePredicate())).
 		Complete(r)
 }

controllers/medusa/medusarestorejob_controller.go

@@ -20,6 +20,7 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
+	custompredicate "github.com/k8ssandra/k8ssandra-operator/pkg/predicate"
 	"net"
 
 	appsv1 "k8s.io/api/apps/v1"
@@ -296,7 +297,7 @@ func updateMedusaRestoreInitContainer(req *medusa.RestoreRequest) error {
 // SetupWithManager sets up the controller with the Manager.
 func (r *MedusaRestoreJobReconciler) SetupWithManager(mgr ctrl.Manager) error {
 	return ctrl.NewControllerManagedBy(mgr).
-		For(&medusav1alpha1.MedusaRestoreJob{}, builder.WithPredicates(predicate.GenerationChangedPredicate{})).
+		For(&medusav1alpha1.MedusaRestoreJob{}, builder.WithPredicates(predicate.GenerationChangedPredicate{}, custompredicate.NewExcludeNamespacePredicate())).
 		Complete(r)
 }
 

controllers/medusa/medusatask_controller.go

@@ -19,6 +19,7 @@ package medusa
 import (
 	"context"
 	"fmt"
+	custompredicate "github.com/k8ssandra/k8ssandra-operator/pkg/predicate"
 	"net"
 	"sync"
 
@@ -427,6 +428,6 @@ func taskFinished(task *medusav1alpha1.MedusaTask) bool {
 // SetupWithManager sets up the controller with the Manager.
 func (r *MedusaTaskReconciler) SetupWithManager(mgr ctrl.Manager) error {
 	return ctrl.NewControllerManagedBy(mgr).
-		For(&medusav1alpha1.MedusaTask{}, builder.WithPredicates(predicate.GenerationChangedPredicate{})).
+		For(&medusav1alpha1.MedusaTask{}, builder.WithPredicates(predicate.GenerationChangedPredicate{}, custompredicate.NewExcludeNamespacePredicate())).
 		Complete(r)
 }

controllers/reaper/reaper_controller.go

@@ -18,6 +18,7 @@ package reaper
 
 import (
 	"context"
+	custompredicate "github.com/k8ssandra/k8ssandra-operator/pkg/predicate"
 
 	"github.com/go-logr/logr"
 	cassdcapi "github.com/k8ssandra/cass-operator/apis/cassandra/v1beta1"
@@ -410,7 +411,7 @@ func (r *ReaperReconciler) getSecret(ctx context.Context, secretKey types.Namesp
 
 func (r *ReaperReconciler) SetupWithManager(mgr ctrl.Manager) error {
 	return ctrl.NewControllerManagedBy(mgr).
-		For(&reaperapi.Reaper{}, builder.WithPredicates(predicate.GenerationChangedPredicate{})).
+		For(&reaperapi.Reaper{}, builder.WithPredicates(predicate.GenerationChangedPredicate{}, custompredicate.NewExcludeNamespacePredicate())).
 		Owns(&appsv1.Deployment{}).
 		Owns(&corev1.Service{}).
 		Complete(r)

controllers/replication/secret_controller.go

@@ -3,6 +3,7 @@ package replication
 import (
 	"context"
 	"fmt"
+	custompredicate "github.com/k8ssandra/k8ssandra-operator/pkg/predicate"
 	"github.com/k8ssandra/k8ssandra-operator/pkg/secret"
 	"strings"
 	"sync"
@@ -390,7 +391,7 @@ func (s *SecretSyncController) SetupWithManager(mgr ctrl.Manager, clusters []clu
 	}
 
 	cb := ctrl.NewControllerManagedBy(mgr).
-		For(&api.ReplicatedSecret{}, builder.WithPredicates(predicate.GenerationChangedPredicate{})).
+		For(&api.ReplicatedSecret{}, builder.WithPredicates(predicate.GenerationChangedPredicate{}, custompredicate.NewExcludeNamespacePredicate())).
 		Watches(&source.Kind{Type: &corev1.Secret{}}, handler.EnqueueRequestsFromMapFunc(toMatchingReplicates))
 
 	for _, c := range clusters {

controllers/stargate/stargate_controller.go

@@ -20,6 +20,7 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
+	custompredicate "github.com/k8ssandra/k8ssandra-operator/pkg/predicate"
 
 	"github.com/go-logr/logr"
 	cassdcapi "github.com/k8ssandra/cass-operator/apis/cassandra/v1beta1"
@@ -482,7 +483,7 @@ func reconcileStargateConfigFile(
 // SetupWithManager sets up the controller with the Manager.
 func (r *StargateReconciler) SetupWithManager(mgr ctrl.Manager) error {
 	return ctrl.NewControllerManagedBy(mgr).
-		For(&api.Stargate{}, builder.WithPredicates(predicate.GenerationChangedPredicate{})).
+		For(&api.Stargate{}, builder.WithPredicates(predicate.GenerationChangedPredicate{}, custompredicate.NewExcludeNamespacePredicate())).
 		Owns(&appsv1.Deployment{}).
 		Owns(&corev1.Service{}).
 		Complete(r)

pkg/predicate/predicate.go

@@ -0,0 +1,50 @@
+package predicate
+
+import (
+	"os"
+	"sigs.k8s.io/controller-runtime/pkg/client"
+	"sigs.k8s.io/controller-runtime/pkg/event"
+	"sigs.k8s.io/controller-runtime/pkg/predicate"
+	"strings"
+)
+
+func NewExcludeNamespacePredicate() predicate.Predicate {
+	var excludeWatchNamespaceEnvVar = "EXCLUDE_WATCH_NAMESPACE"
+
+	excludeWatchNamespace, found := os.LookupEnv(excludeWatchNamespaceEnvVar)
+	if !found {
+		return predicate.NewPredicateFuncs(func(object client.Object) bool {
+			return true
+		})
+	}
+	var excludeNamespacesList []string
+	if strings.Contains(excludeWatchNamespace, ",") {
+		excludeNamespacesList = strings.Split(excludeWatchNamespace, ",")
+	} else {
+		excludeNamespacesList = []string{excludeWatchNamespace}
+	}
+
+	return predicate.Funcs{
+		UpdateFunc: func(e event.UpdateEvent) bool {
+			return shouldBeProcessed(excludeNamespacesList, e.ObjectNew.GetNamespace())
+		},
+		DeleteFunc: func(e event.DeleteEvent) bool {
+			return shouldBeProcessed(excludeNamespacesList, e.Object.GetNamespace())
+		},
+		CreateFunc: func(createEvent event.CreateEvent) bool {
+			return shouldBeProcessed(excludeNamespacesList, createEvent.Object.GetNamespace())
+		},
+		GenericFunc: func(genericEvent event.GenericEvent) bool {
+			return shouldBeProcessed(excludeNamespacesList, genericEvent.Object.GetNamespace())
+		},
+	}
+}
+
+func shouldBeProcessed(excludeNamespacesList []string, namespace string) bool {
+	for _, excludeNs := range excludeNamespacesList {
+		if excludeNs == namespace {
+			return false
+		}
+	}
+	return true
+}