workqueue

Oct 15, 2025

Changes in this version

+ func ExponentialFailureRateLimiter[T comparable](failInitialWait, failMaxWait time.Duration) workqueue.TypedRateLimiter[T]

+ func IngressReconcilerRateLimiter[T comparable](rateLimitUpdate float64, waitBeforeUpdate time.Duration) workqueue.TypedRateLimiter[T]

+ func ReloadHAProxyRateLimiter(reloadInterval time.Duration) workqueue.TypedRateLimiter[any]

+ type Options struct

+ Workers int

+ type SyncCallback func(context.Context, T) error

+ type WorkQueue struct

+ func New[T comparable](sync SyncCallback[T], rateLimiter workqueue.TypedRateLimiter[T], ...) *WorkQueue[T]

+ func (w *WorkQueue[T]) Add(item T)

+ func (w *WorkQueue[T]) AddAfter(item T, duration time.Duration)

+ func (w *WorkQueue[T]) Len() int

+ func (w *WorkQueue[T]) Remove(item T)

+ func (w *WorkQueue[T]) Start(ctx context.Context) error