refactor: namespace auto propagation controller

cmd/controller-manager/app/controllermanager.go

@@ -35,14 +35,16 @@ import (
 )
 
 const (
-	FederatedClusterControllerName = "cluster"
-	FederateControllerName         = "federate"
-	MonitorControllerName          = "monitor"
-	FollowerControllerName         = "follower"
+	FederatedClusterControllerName         = "cluster"
+	FederateControllerName                 = "federate"
+	MonitorControllerName                  = "monitor"
+	FollowerControllerName                 = "follower"
+	NamespaceAutoPropagationControllerName = "nsautoprop"
 )
 
 var knownControllers = map[string]controllermanager.StartControllerFunc{
-	FederateControllerName: startFederateController,
+	FederateControllerName:                 startFederateController,
+	NamespaceAutoPropagationControllerName: startNamespaceAutoPropagationController,
 }
 
 var controllersDisabledByDefault = sets.New(MonitorControllerName)

cmd/controller-manager/app/core.go

@@ -25,6 +25,7 @@ import (
 	"github.com/kubewharf/kubeadmiral/pkg/controllermanager"
 	controllercontext "github.com/kubewharf/kubeadmiral/pkg/controllers/context"
 	"github.com/kubewharf/kubeadmiral/pkg/controllers/federate"
+	"github.com/kubewharf/kubeadmiral/pkg/controllers/nsautoprop"
 )
 
 func startFederateController(
@@ -51,3 +52,29 @@ func startFederateController(
 
 	return federateController, nil
 }
+
+func startNamespaceAutoPropagationController(
+	ctx context.Context,
+	controllerCtx *controllercontext.Context,
+) (controllermanager.Controller, error) {
+	nsAutoPropController, err := nsautoprop.NewNamespaceAutoPropagationController(
+		controllerCtx.KubeClientset,
+		controllerCtx.InformerManager,
+		controllerCtx.FedClientset,
+		controllerCtx.FedInformerFactory.Core().V1alpha1().FederatedClusters(),
+		controllerCtx.FedInformerFactory.Core().V1alpha1().ClusterFederatedObjects(),
+		controllerCtx.KubeInformerFactory.Core().V1().Namespaces(),
+		controllerCtx.ComponentConfig.NSAutoPropExcludeRegexp,
+		controllerCtx.FedSystemNamespace,
+		controllerCtx.Metrics,
+		klog.Background(),
+		controllerCtx.WorkerCount,
+	)
+	if err != nil {
+		return nil, fmt.Errorf("error creating namespace auto propagation controller: %w", err)
+	}
+
+	go nsAutoPropController.Run(ctx)
+
+	return nsAutoPropController, nil
+}