ratelimiter

Documentation

Index

• func NewCustomAppControllerRateLimiter(cfg *AppControllerRateLimiterConfig) workqueue.TypedRateLimiter[string]
• func NewItemExponentialRateLimiterWithAutoReset(baseDelay, maxDelay, failureCoolDown time.Duration, backoffFactor float64) workqueue.TypedRateLimiter[string]
• type AppControllerRateLimiterConfig
  • func GetDefaultAppRateLimiterConfig() *AppControllerRateLimiterConfig
• type ItemExponentialRateLimiterWithAutoReset
  • func (r *ItemExponentialRateLimiterWithAutoReset) Forget(item string)
  • func (r *ItemExponentialRateLimiterWithAutoReset) NumRequeues(item string) int
  • func (r *ItemExponentialRateLimiterWithAutoReset) When(item string) time.Duration

Functions

func NewCustomAppControllerRateLimiter

func NewCustomAppControllerRateLimiter(cfg *AppControllerRateLimiterConfig) workqueue.TypedRateLimiter[string]

NewCustomAppControllerRateLimiter is a constructor for the rate limiter for a workqueue used by app controller. It has both overall and per-item rate limiting. The overall is a token bucket and the per-item is exponential(with auto resets)

func NewItemExponentialRateLimiterWithAutoReset

func NewItemExponentialRateLimiterWithAutoReset(baseDelay, maxDelay, failureCoolDown time.Duration, backoffFactor float64) workqueue.TypedRateLimiter[string]

Types

type AppControllerRateLimiterConfig

type AppControllerRateLimiterConfig struct {
	BucketSize      int64
	BucketQPS       float64
	FailureCoolDown time.Duration
	BaseDelay       time.Duration
	MaxDelay        time.Duration
	BackoffFactor   float64
}

func GetDefaultAppRateLimiterConfig

func GetDefaultAppRateLimiterConfig() *AppControllerRateLimiterConfig

type ItemExponentialRateLimiterWithAutoReset

type ItemExponentialRateLimiterWithAutoReset struct {
	// contains filtered or unexported fields
}

ItemExponentialRateLimiterWithAutoReset does a simple baseDelay*2^<num-failures> limit dealing with max failures and expiration/resets are up dependent on the cooldown period

func (*ItemExponentialRateLimiterWithAutoReset) Forget

func (r *ItemExponentialRateLimiterWithAutoReset) Forget(item string)

func (*ItemExponentialRateLimiterWithAutoReset) NumRequeues

func (r *ItemExponentialRateLimiterWithAutoReset) NumRequeues(item string) int

func (*ItemExponentialRateLimiterWithAutoReset) When

func (r *ItemExponentialRateLimiterWithAutoReset) When(item string) time.Duration