workqueue

Aug 25, 2025

Changes in this version

+ func NewExponentialTimedFailureRateLimiter[T comparable](baseDelay time.Duration, maxDelay time.Duration) workqueue.TypedRateLimiter[T]

+ type FailureRequest struct

+ Attempts int

+ LastAttempt time.Time

+ type TypedItemExponentialTimedFailureRateLimiter struct

+ func (r *TypedItemExponentialTimedFailureRateLimiter[T]) Forget(item T)

+ func (r *TypedItemExponentialTimedFailureRateLimiter[T]) NumRequeues(item T) int

+ func (r *TypedItemExponentialTimedFailureRateLimiter[T]) When(item T) time.Duration