in cmd/mcs-controller-manager/main.go [243:285]
func setupControllersWithManager(_ context.Context, hubMgr, memberMgr manager.Manager) error {
klog.V(1).InfoS("Begin to setup controllers with controller manager")
memberClient := memberMgr.GetClient()
hubClient := hubMgr.GetClient()
klog.V(1).InfoS("Create multiclusterservice reconciler")
if err := (&multiclusterservice.Reconciler{
Client: memberClient,
Scheme: memberMgr.GetScheme(),
FleetSystemNamespace: *fleetSystemNamespace,
Recorder: memberMgr.GetEventRecorderFor(multiclusterservice.ControllerName),
}).SetupWithManager(memberMgr); err != nil {
klog.ErrorS(err, "Unable to create multiclusterservice reconciler")
return err
}
if *isV1Alpha1APIEnabled {
klog.V(1).InfoS("Create internalmembercluster (v1alpha1 API) reconciler")
if err := (&imcv1alpha1.Reconciler{
MemberClient: memberClient,
HubClient: hubClient,
AgentType: fleetv1alpha1.MultiClusterServiceAgent,
}).SetupWithManager(hubMgr); err != nil {
klog.ErrorS(err, "Unable to create internalmembercluster (v1alpha1 API) reconciler")
return err
}
}
if *isV1Beta1APIEnabled {
klog.V(1).InfoS("Create internalmembercluster (v1beta1 API) reconciler")
if err := (&imcv1beta1.Reconciler{
MemberClient: memberClient,
HubClient: hubClient,
AgentType: clusterv1beta1.MultiClusterServiceAgent,
}).SetupWithManager(hubMgr); err != nil {
klog.ErrorS(err, "Unable to create internalmembercluster (v1beta1 API) reconciler")
return err
}
}
klog.V(1).InfoS("Succeeded to setup controllers with controller manager")
return nil
}