Package wait provides tools for polling or listening for changes to a condition.

DefaultControllerRateLimiter is a no-arg constructor for a default rate limiter for a workqueue.

New constructs a new work queue (see the package comment).

NewDelayingQueue constructs a new workqueue with delayed queuing ability.

NewDelayingQueueWithConfig constructs a new workqueue with options to customize different properties.

NewDelayingQueueWithCustomClock constructs a new named workqueue with ability to inject real or fake clock for testing purposes.

NewDelayingQueueWithCustomQueue constructs a new workqueue with ability to inject custom queue Interface instead of the default one Deprecated: Use NewDelayingQueueWithConfig instead.

NewNamed creates a new named queue.

NewNamedDelayingQueue constructs a new named workqueue with delayed queuing ability.

NewNamedRateLimitingQueue constructs a new named workqueue with rateLimited queuing ability.

NewRateLimitingQueue constructs a new workqueue with rateLimited queuing ability Remember to call Forget! If you don't, you may end up tracking failures forever.

NewRateLimitingQueueWithConfig constructs a new workqueue with rateLimited queuing ability with options to customize different properties.

NewRateLimitingQueueWithDelayingInterface constructs a new named workqueue with rateLimited queuing ability with the option to inject a custom delaying queue instead of the default one.

NewWithConfig constructs a new workqueue with ability to customize different properties.

ParallelizeUntil is a framework that allows for parallelizing N independent pieces of work until done or the context is canceled.

SetProvider sets the metrics provider for all subsequently created work queues.

WithChunkSize allows to set chunks of work items to the workers, rather than processing one by one.

BucketRateLimiter adapts a standard bucket to the workqueue ratelimiter API.

DelayingQueueConfig specifies optional configurations to customize a DelayingInterface.

ItemExponentialFailureRateLimiter does a simple baseDelay*2^<num-failures> limit dealing with max failures and expiration are up to the caller.

ItemFastSlowRateLimiter does a quick retry for a certain number of attempts, then a slow retry after that.

MaxOfRateLimiter calls every RateLimiter and returns the worst case response When used with a token bucket limiter, the burst could be apparently exceeded in cases where particular items were separately delayed a longer time.

QueueConfig specifies optional configurations to customize an Interface.

Type is a work queue (see the package comment).

WithMaxWaitRateLimiter have maxDelay which avoids waiting too long.

CounterMetric represents a single numerical value that only ever goes up.

DelayingInterface is an Interface that can Add an item at a later time.

GaugeMetric represents a single numerical value that can arbitrarily go up and down.

HistogramMetric counts individual observations.

MetricsProvider generates various metrics used by the queue.

RateLimitingInterface is an interface that rate limits items being added to the queue.

SettableGaugeMetric represents a single numerical value that can arbitrarily go up and down.

SummaryMetric captures individual observations.