Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDefaultControllerRateLimiter ¶
func NewDefaultControllerRateLimiter() workqueue.RateLimiter
func NewJitteredFastSlowRateLimiter ¶
func NewJitteredFastSlowRateLimiter(fastDelay, slowDelay time.Duration, maxFastAttempts int) workqueue.RateLimiter
Types ¶
type JitteredRateLimiter ¶
type JitteredRateLimiter struct {
workqueue.RateLimiter
}
JitteredRateLimiter does a quick retry for a certain number of attempts, then slow retries afterwards. It also adds some jitter to prevent Thundering Herds from happening.
func (*JitteredRateLimiter) When ¶
func (r *JitteredRateLimiter) When(item interface{}) time.Duration
Source Files
Click to show internal directories.
Click to hide internal directories.