From a9070dbcc3211b41c338ec2ce0f455172fa5b704 Mon Sep 17 00:00:00 2001 From: Sunny Date: Wed, 4 Jan 2023 13:36:33 +0000 Subject: [PATCH] Expose the default rate limiter The default configurations for rate limiter is exposed only to flag set. This change adds a new function GetDefaultRateLimiter() to provide access to the same rate limiter configuration without flags. This is useful for setting the default rate limiter for reconcilers in test suites. Signed-off-by: Sunny --- runtime/controller/rate_limiter.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/runtime/controller/rate_limiter.go b/runtime/controller/rate_limiter.go index eaf47e8a..17c56fb8 100644 --- 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) +}