BackoffUntil loops until stop channel is closed, run f every duration given by BackoffManager.

ContextForChannel derives a child context from a parent channel.

Jitter returns a time.Duration between duration and duration + maxFactor * duration.

JitterUntil loops until stop channel is closed, running f every period.

NewErrorChannel returns a new ErrorChannel.

NewExponentialBackoffManager returns a manager for managing exponential backoff.

NewJitteredBackoffManager returns a BackoffManager that backoffs with given duration plus given jitter.

NewParallelizer returns an object holding the parallelism.

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

PollImmediateUntil tries a condition func until it returns true, an error or stopCh is closed.

PollImmediateUntilWithContext tries a condition func until it returns true, an error or the specified context is canceled or expired.

Until loops until stop channel is closed, running f every period.

UntilWithContext loops until context is done, running f every period.

WaitForWithContext continually checks 'fn' as driven by 'wait'.

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

DefaultParallelism is the default parallelism used in scheduler.

ErrWaitTimeout is returned when the condition exited without success.

Backoff holds parameters applied to a Backoff function.

ErrorChannel supports non-blocking send and receive operation to capture error.

Group allows to start a group of goroutines and wait for their completion.

Parallelizer holds the parallelism for scheduler.

ConditionFunc returns true if the condition is satisfied, or an error if the loop should be aborted.

ConditionWithContextFunc returns true if the condition is satisfied, or an error if the loop should be aborted.

WaitWithContextFunc creates a channel that receives an item every time a test should be executed and is closed when the last test should be invoked.