@@ -37,6 +37,7 @@ import (
3737 "github.com/kubefleet-dev/kubefleet/pkg/controllers/clusterinventory/clusterprofile"
3838 "github.com/kubefleet-dev/kubefleet/pkg/controllers/clusterresourceplacementeviction"
3939 "github.com/kubefleet-dev/kubefleet/pkg/controllers/clusterresourceplacementstatuswatcher"
40+ "github.com/kubefleet-dev/kubefleet/pkg/controllers/memberclusterplacement"
4041 "github.com/kubefleet-dev/kubefleet/pkg/controllers/overrider"
4142 "github.com/kubefleet-dev/kubefleet/pkg/controllers/placement"
4243 "github.com/kubefleet-dev/kubefleet/pkg/controllers/placementwatcher"
@@ -69,7 +70,8 @@ const (
6970
7071 resourceChangeControllerName = "resource-change-controller"
7172
72- schedulerQueueName = "scheduler-queue"
73+ schedulerQueueName = "scheduler-queue"
74+ mcPlacementControllerName = "memberCluster-placement-controller"
7375)
7476
7577var (
@@ -174,6 +176,13 @@ func SetupControllers(ctx context.Context, wg *sync.WaitGroup, mgr ctrl.Manager,
174176 var clusterResourcePlacementControllerV1Beta1 controller.Controller
175177 var resourcePlacementController controller.Controller
176178 var memberClusterPlacementController controller.Controller
179+ if opts .EnableV1Alpha1APIs {
180+ klog .Info ("Setting up member cluster change controller" )
181+ mcp := & memberclusterplacement.Reconciler {
182+ InformerManager : dynamicInformerManager ,
183+ }
184+ memberClusterPlacementController = controller .NewController (mcPlacementControllerName , controller .NamespaceKeyFunc , mcp .Reconcile , rateLimiter )
185+ }
177186
178187 if opts .EnableV1Beta1APIs {
179188 for _ , gvk := range v1Beta1RequiredGVKs {
0 commit comments