Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewExponentialTimedFailureRateLimiter ¶
func NewExponentialTimedFailureRateLimiter[T comparable](baseDelay time.Duration, maxDelay time.Duration) workqueue.TypedRateLimiter[T]
Types ¶
type FailureRequest ¶
type TypedItemExponentialTimedFailureRateLimiter ¶
type TypedItemExponentialTimedFailureRateLimiter[T comparable] struct { // contains filtered or unexported fields }
func (*TypedItemExponentialTimedFailureRateLimiter[T]) Forget ¶
func (r *TypedItemExponentialTimedFailureRateLimiter[T]) Forget(item T)
func (*TypedItemExponentialTimedFailureRateLimiter[T]) NumRequeues ¶
func (r *TypedItemExponentialTimedFailureRateLimiter[T]) NumRequeues(item T) int
func (*TypedItemExponentialTimedFailureRateLimiter[T]) When ¶
func (r *TypedItemExponentialTimedFailureRateLimiter[T]) When(item T) time.Duration
Click to show internal directories.
Click to hide internal directories.