Add ratelimiter to boshdeployment controllers

cloudfoundry-incubator · May 25, 2021 · b052aab · b052aab
1 parent f7abba5
commit b052aab
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 0 deletions.
diff --git a/pkg/kube/controllers/boshdeployment/bpm_controller.go b/pkg/kube/controllers/boshdeployment/bpm_controller.go
@@ -23,6 +23,7 @@ import (
 	"code.cloudfoundry.org/quarks-utils/pkg/meltdown"
 	"code.cloudfoundry.org/quarks-utils/pkg/monitorednamespace"
 	"code.cloudfoundry.org/quarks-utils/pkg/names"
+	"code.cloudfoundry.org/quarks-utils/pkg/ratelimiter"
 	vss "code.cloudfoundry.org/quarks-utils/pkg/versionedsecretstore"
 )
 
@@ -43,6 +44,7 @@ func AddBPM(ctx context.Context, config *config.Config, mgr manager.Manager) err
 	c, err := controller.New("bpm-controller", mgr, controller.Options{
 		Reconciler:              r,
 		MaxConcurrentReconciles: config.MaxBoshDeploymentWorkers,
+		RateLimiter:             ratelimiter.New(),
 	})
 	if err != nil {
 		return errors.Wrap(err, "Adding BPM controller to manager failed.")

diff --git a/pkg/kube/controllers/boshdeployment/deployment_controller.go b/pkg/kube/controllers/boshdeployment/deployment_controller.go
@@ -28,6 +28,7 @@ import (
 	"code.cloudfoundry.org/quarks-utils/pkg/config"
 	"code.cloudfoundry.org/quarks-utils/pkg/ctxlog"
 	"code.cloudfoundry.org/quarks-utils/pkg/monitorednamespace"
+	"code.cloudfoundry.org/quarks-utils/pkg/ratelimiter"
 	"code.cloudfoundry.org/quarks-utils/pkg/skip"
 )
 
@@ -51,6 +52,7 @@ func AddDeployment(ctx context.Context, config *config.Config, mgr manager.Manag
 	c, err := controller.New("boshdeployment-controller", mgr, controller.Options{
 		Reconciler:              r,
 		MaxConcurrentReconciles: config.MaxBoshDeploymentWorkers,
+		RateLimiter:             ratelimiter.New(),
 	})
 	if err != nil {
 		return errors.Wrap(err, "Adding Bosh deployment controller to manager failed.")

diff --git a/pkg/kube/controllers/boshdeployment/withops_controller.go b/pkg/kube/controllers/boshdeployment/withops_controller.go
@@ -28,6 +28,7 @@ import (
 	"code.cloudfoundry.org/quarks-utils/pkg/ctxlog"
 	"code.cloudfoundry.org/quarks-utils/pkg/monitorednamespace"
 	"code.cloudfoundry.org/quarks-utils/pkg/names"
+	"code.cloudfoundry.org/quarks-utils/pkg/ratelimiter"
 	"code.cloudfoundry.org/quarks-utils/pkg/skip"
 )
 
@@ -50,6 +51,7 @@ func AddWithOps(ctx context.Context, config *config.Config, mgr manager.Manager)
 	c, err := controller.New("withops-controller", mgr, controller.Options{
 		Reconciler:              r,
 		MaxConcurrentReconciles: config.MaxBoshDeploymentWorkers,
+		RateLimiter:             ratelimiter.New(),
 	})
 	if err != nil {
 		return errors.Wrap(err, "Adding withops controller to manager failed.")