From b052aabab876e7920caf3dccd3b4ae6728577ad7 Mon Sep 17 00:00:00 2001 From: Mario Manno Date: Tue, 8 Dec 2020 10:42:44 +0100 Subject: [PATCH] Add ratelimiter to boshdeployment controllers --- pkg/kube/controllers/boshdeployment/bpm_controller.go | 2 ++ pkg/kube/controllers/boshdeployment/deployment_controller.go | 2 ++ pkg/kube/controllers/boshdeployment/withops_controller.go | 2 ++ 3 files changed, 6 insertions(+) diff --git a/pkg/kube/controllers/boshdeployment/bpm_controller.go b/pkg/kube/controllers/boshdeployment/bpm_controller.go index 735cc227f..98288298a 100644 --- 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 index 26420690c..284175bc9 100644 --- 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 index 51f127c3f..ddcb34ffd 100644 --- 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.")