Configure replicator worker count

- configure service binding replicator worker count using BindingWorkerCount - configure service instance replicator worker count using InstanceWorkerCount
cloudfoundry · Mar 5, 2021 · ed609f0 · ed609f0
1 parent 78ddfc3
commit ed609f0
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/...rs/multiclusterdeploy/sfservicebindingreplicator/sfservicebindingreplicator_controller.go b/...rs/multiclusterdeploy/sfservicebindingreplicator/sfservicebindingreplicator_controller.go
@@ -35,6 +35,7 @@ import (
 	"k8s.io/client-go/util/retry"
 	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/handler"
 	"sigs.k8s.io/controller-runtime/pkg/source"
 )
@@ -346,6 +347,7 @@ func (r *BindingReplicator) SetupWithManager(mgr ctrl.Manager) error {
 	if err != nil {
 		return err
 	}
+	interoperatorCfg := cfgManager.GetConfig()
 	r.cfgManager = cfgManager
 	// Watch for changes to SFServiceBinding in sister clusters
 	watchEvents, err := getWatchChannel("sfservicebindings")
@@ -355,6 +357,9 @@ func (r *BindingReplicator) SetupWithManager(mgr ctrl.Manager) error {
 
 	builder := ctrl.NewControllerManagedBy(mgr).
 		Named("mcd_replicator_binding").
+		WithOptions(controller.Options{
+			MaxConcurrentReconciles: interoperatorCfg.BindingWorkerCount,
+		}).
 		For(&osbv1alpha1.SFServiceBinding{}).
 		Watches(&source.Channel{Source: watchEvents}, &handler.EnqueueRequestForObject{}).
 		WithEventFilter(watches.NamespaceLabelFilter())

diff --git a/.../multiclusterdeploy/sfserviceinstancereplicator/sfserviceinstancereplicator_controller.go b/.../multiclusterdeploy/sfserviceinstancereplicator/sfserviceinstancereplicator_controller.go
@@ -35,6 +35,7 @@ import (
 	"k8s.io/client-go/util/retry"
 	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/handler"
 	"sigs.k8s.io/controller-runtime/pkg/metrics"
 	"sigs.k8s.io/controller-runtime/pkg/source"
@@ -409,6 +410,7 @@ func (r *InstanceReplicator) SetupWithManager(mgr ctrl.Manager) error {
 	if err != nil {
 		return err
 	}
+	interoperatorCfg := cfgManager.GetConfig()
 	r.cfgManager = cfgManager
 
 	// Watch for changes to SFServiceInstance in sister clusters
@@ -421,6 +423,9 @@ func (r *InstanceReplicator) SetupWithManager(mgr ctrl.Manager) error {
 
 	builder := ctrl.NewControllerManagedBy(mgr).
 		Named("mcd_replicator_instance").
+		WithOptions(controller.Options{
+			MaxConcurrentReconciles: interoperatorCfg.InstanceWorkerCount,
+		}).
 		For(&osbv1alpha1.SFServiceInstance{}).
 		Watches(&source.Channel{Source: watchEvents}, &handler.EnqueueRequestForObject{}).
 		WithEventFilter(watches.NamespaceLabelFilter())