set MaxConcurrentReconciles for VolumeReplication

Added option to set MaxConcurrentReconciles
for VolumeReplication which was pending and for
all other controllers this is set in csi-addons#203

Signed-off-by: Madhu Rajanna <[email protected]>

cmd/manager/main.go

@@ -146,7 +146,7 @@ func main() {
 		Connpool: connPool,
 		Timeout:  defaultTimeout,
 		Log:      ctrl.Log.WithName("controllers").WithName("VolumeReplication"),
-	}).SetupWithManager(mgr); err != nil {
+	}).SetupWithManager(mgr, ctrlOptions); err != nil {
 		setupLog.Error(err, "unable to create controller", "controller", "VolumeReplication")
 		os.Exit(1)
 	}

controllers/replication.storage/volumereplication_controller.go

@@ -41,6 +41,7 @@ import (
 	"k8s.io/apimachinery/pkg/types"
 	ctrl "sigs.k8s.io/controller-runtime"
 	"sigs.k8s.io/controller-runtime/pkg/client"
+	"sigs.k8s.io/controller-runtime/pkg/controller"
 	"sigs.k8s.io/controller-runtime/pkg/predicate"
 	"sigs.k8s.io/controller-runtime/pkg/reconcile"
 )
@@ -385,7 +386,7 @@ func (r *VolumeReplicationReconciler) updateReplicationStatus(
 }
 
 // SetupWithManager sets up the controller with the Manager.
-func (r *VolumeReplicationReconciler) SetupWithManager(mgr ctrl.Manager) error {
+func (r *VolumeReplicationReconciler) SetupWithManager(mgr ctrl.Manager, ctrlOptions controller.Options) error {
 	err := r.waitForCrds()
 	if err != nil {
 		r.Log.Error(err, "failed to wait for crds")
@@ -397,7 +398,9 @@ func (r *VolumeReplicationReconciler) SetupWithManager(mgr ctrl.Manager) error {
 
 	return ctrl.NewControllerManagedBy(mgr).
 		For(&replicationv1alpha1.VolumeReplication{}).
-		WithEventFilter(pred).Complete(r)
+		WithEventFilter(pred).
+		WithOptions(ctrlOptions).
+		Complete(r)
 }
 
 func (r *VolumeReplicationReconciler) waitForCrds() error {