ratelimiterflag

Documentation

Index

• func DefaultControllerRateLimiter[T comparable](opts Options) workqueue.TypedRateLimiter[T]
• type Options
  • func (o *Options) AddFlags(fs *pflag.FlagSet)

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) AddFlags

func (o *Options) AddFlags(fs *pflag.FlagSet)

AddFlags adds flags to the specified FlagSet.