Merge pull request #443 from fluxcd/default-rate-limiter

Expose the default rate limiter
fluxcd · Jan 10, 2023 · 25ef474 · 25ef474
2 parents 75f797c + a9070db
commit 25ef474
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/runtime/controller/rate_limiter.go b/runtime/controller/rate_limiter.go
@@ -59,3 +59,11 @@ func GetRateLimiter(opts RateLimiterOptions) ratelimiter.RateLimiter {
 		opts.MinRetryDelay,
 		opts.MaxRetryDelay)
 }
+
+// GetDefaultRateLimiter returns a new exponential failure
+// ratelimiter.RateLimiter with the default configuration.
+func GetDefaultRateLimiter() ratelimiter.RateLimiter {
+	return workqueue.NewItemExponentialFailureRateLimiter(
+		defaultMinRetryDelay,
+		defaultMaxRetryDelay)
+}