Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DefaultControllerRateLimiter ¶
func DefaultControllerRateLimiter[T comparable](opts Options) workqueue.TypedRateLimiter[T]
DefaultControllerRateLimiter provide a default rate limiter for controller, and users can tune it by corresponding flags.
Types ¶
type Options ¶
type Options struct {
// RateLimiterBaseDelay is the base delay for ItemExponentialFailureRateLimiter.
RateLimiterBaseDelay time.Duration
// RateLimiterMaxDelay is the max delay for ItemExponentialFailureRateLimiter.
RateLimiterMaxDelay time.Duration
// RateLimiterQPS is the qps for BucketRateLimiter
RateLimiterQPS int
// RateLimiterBucketSize is the bucket size for BucketRateLimiter
RateLimiterBucketSize int
}
Options are options for rate limiter.
func (*Options) SetDefaults ¶ added in v1.16.0
SetDefaults sets the default values for Options.
Click to show internal directories.
Click to hide internal directories.