Merge pull request #36 from cybozu-go/kaizen/skip-mbc-reconciliation-…

…if-secondary

skip reconciliation if role is secondary

cmd/controller/main.go

@@ -136,12 +136,14 @@ func setupReconcilers(mgr manager.Manager, primarySettings *controller.PrimarySe
 		setupLog.Error(err, "unable to create controller", "controller", "MantleRestore")
 		return err
 	}
+
 	if err := controller.NewMantleBackupConfigReconciler(
 		mgr.GetClient(),
 		mgr.GetScheme(),
 		managedCephClusterID,
 		expireOffset,
 		overwriteMBCSchedule,
+		role,
 	).SetupWithManager(mgr); err != nil {
 		setupLog.Error(err, "unable to create controller", "controller", "MantleBackupConfig")
 		return err

internal/controller/mantlebackupconfig_controller.go

@@ -34,10 +34,18 @@ type MantleBackupConfigReconciler struct {
 	managedCephClusterID string
 	expireOffset         string
 	overwriteMBCSchedule string
+	role                 string
 }
 
-func NewMantleBackupConfigReconciler(cli client.Client, scheme *runtime.Scheme, managedCephClusterID string, expireOffset string, overwriteMBCSchedule string) *MantleBackupConfigReconciler {
-	return &MantleBackupConfigReconciler{cli, scheme, managedCephClusterID, expireOffset, overwriteMBCSchedule}
+func NewMantleBackupConfigReconciler(
+	cli client.Client,
+	scheme *runtime.Scheme,
+	managedCephClusterID string,
+	expireOffset string,
+	overwriteMBCSchedule string,
+	role string,
+) *MantleBackupConfigReconciler {
+	return &MantleBackupConfigReconciler{cli, scheme, managedCephClusterID, expireOffset, overwriteMBCSchedule, role}
 }
 
 //+kubebuilder:rbac:groups=mantle.cybozu.io,resources=mantlebackupconfigs,verbs=get;list;watch;create;update;patch;delete
@@ -56,6 +64,10 @@ func NewMantleBackupConfigReconciler(cli client.Client, scheme *runtime.Scheme,
 // For more details, check Reconcile and its Result here:
 // - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.16.3/pkg/reconcile
 func (r *MantleBackupConfigReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
+	if r.role == RoleSecondary {
+		return ctrl.Result{}, nil
+	}
+
 	// Get the CronJob info to be created or updated
 	cronJobInfo, err := getCronJobInfo(ctx, r.Client)
 	if err != nil {

internal/controller/mantlebackupconfig_controller_test.go

@@ -171,7 +171,7 @@ var _ = Describe("MantleBackupConfig controller", func() {
 		})
 		Expect(err).ToNot(HaveOccurred())
 
-		reconciler = NewMantleBackupConfigReconciler(k8sClient, mgr.GetScheme(), storageClassClusterID, "0s", "")
+		reconciler = NewMantleBackupConfigReconciler(k8sClient, mgr.GetScheme(), storageClassClusterID, "0s", "", RoleStandalone)
 		err = reconciler.SetupWithManager(mgr)
 		Expect(err).NotTo(HaveOccurred())