ratelimiter

Nov 25, 2025

Changes in this version

+ type Config struct

+ ExponentialInitialBackoff time.Duration

+ ExponentialMaxBackoff time.Duration

+ StaticRequeueDelay time.Duration

+ StaticWindow time.Duration

+ func NewConfig(options ...Option) Config

+ type Option func(*Config)

+ func WithExponentialInitialBackoff(d time.Duration) Option

+ func WithExponentialMaxBackoff(d time.Duration) Option

+ func WithRequeueDelay(d time.Duration) Option

+ func WithStaticWindow(d time.Duration) Option

+ type StaticThenExponentialRateLimiter struct

+ func NewStaticThenExponentialRateLimiter[T comparable](cfg Config) (*StaticThenExponentialRateLimiter[T], error)

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

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

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