workqueue

type BucketRateLimiter[T comparable] struct {
	*rate.Limiter
}

type ItemExponentialFailureRateLimiter[T comparable] struct {
	// contains filtered or unexported fields
}

type ItemFastSlowRateLimiter[T comparable] struct {
	// contains filtered or unexported fields
}

type ItemRedisTokenRateLimiter[T comparable] struct {
	// contains filtered or unexported fields
}

type MaxOfRateLimiter[T comparable] struct {
	// contains filtered or unexported fields
}

type RateLimiter[T comparable] interface {
	// Take gets an item and gets to decide whether it should run now or not,
	// use this method if you intend to drop / skip events that exceed the rate.
	Take(ctx context.Context, item T) bool
	// When gets an item and gets to decide how long that item should wait,
	// use this method if you wish to wait and slow down in accordance with the rate limit without dropping events.
	When(ctx context.Context, item T) time.Duration
	// Forget indicates that an item is finished being retried. Doesn't matter whether it's for failing
	// or for success, we'll stop tracking it
	Forget(ctx context.Context, item T)
	// Retries returns back how many failures the item has had
	Retries(ctx context.Context, item T) int
}