# Functions
DefaultControllerRateLimiter is a no-arg constructor for a default rate limiter for a workqueue.
No description provided by the author
New constructs a new work queue (see the package comment).
NewDelayingQueue constructs a new workqueue with delayed queuing ability.
NewDelayingQueueWithCustomClock constructs a new named workqueue with ability to inject real or fake clock for testing purposes.
NewDelayingQueueWithCustomQueue constructs a new workqueue with ability to inject custom queue Interface instead of the default one.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
NewNamedDelayingQueue constructs a new named workqueue with delayed queuing ability.
No description provided by the author
NewRateLimitingQueue constructs a new workqueue with rateLimited queuing ability Remember to call Forget! If you don't, you may end up tracking failures forever.
No description provided by the author
# Structs
BucketRateLimiter adapts a standard bucket to the workqueue ratelimiter API.
ItemExponentialFailureRateLimiter does a simple baseDelay*2^<num-failures> limit dealing with max failures and expiration are up to the caller.
ItemFastSlowRateLimiter does a quick retry for a certain number of attempts, then a slow retry after that.
MaxOfRateLimiter calls every RateLimiter and returns the worst case response When used with a token bucket limiter, the burst could be apparently exceeded in cases where particular items were separately delayed a longer time.
Type is a work queue (see the package comment).
WithMaxWaitRateLimiter have maxDelay which avoids waiting too long.
# Interfaces
DelayingInterface is an Interface that can Add an item at a later time.
No description provided by the author
No description provided by the author
RateLimitingInterface is an interface that rate limits items being added to the queue.