New returns a state manager which uses Redis as the backing state store.

NewClusterLuaScript creates a Lua instance whose Lua.Exec uses EVALSHA and EVAL.

QueueItemIndexerFunc returns default queue item indexes for a given queue item.

WithAllowQueueNames specifies that the worker can only select jobs from queue partitions within the given list of names.

WithClock allows replacing the queue's default (real) clock by a mock, for testing.

WithConcurrencyLimitGetter assigns a function that returns concurrency limits for a given partition.

WithCustomConcurrencyKeyLimitRefresher assigns a function that returns concurrency keys with current limits for a given queue item, eg.

WithDenyQueueNames specifies that the worker cannot select jobs from queue partitions within the given list of names.

WithIdempotencyTTLFunc returns custom idempotecy durations given a QueueItem.

WithKindToQueueMapping maps queue.Item.Kind strings to queue names.

WithPollTick specifies the interval at which the queue will poll the backing store for available partitions.

WithShardedClient uses an already connected redis client.

WithConcurrencyLimitGetter assigns a function that returns concurrency limits for a given partition.

WithUnshardedClient uses an already connected redis client.

FunctionStartScoreBufferTime is the grace period used to compare function start times to edge enqueue times.

PartitionConcurrencyLimitRequeueExtension is the length of time that a partition is requeued if there is no global or partition(function) capacity because of concurrency limits.

PartitionLeaseDuration dictates how long a worker holds the lease for a partition.

PartitionRequeueExtension is the length of time that we extend a partition's vesting time when requeueing by default.

threshold 25%.

default values.

AccountLeaseTime is how long accounts with guaranteed capacity are leased.

ErrConcurrencyLimitCustomKey represents a concurrency limit being hit for *some*, but *not all* jobs in a queue, via custom concurrency keys which are evaluated to a specific string.

ErrSystemConcurrencyLimit represents a concurrency limit for system partitions.

How many accounts to lease on a single worker when processing guaranteed capacity.

GuaranteedCapacityTickTime is the duration in which we periodically check guaranteed capacity for lease information, etc.

Config registers the configuration for the in-memory state store, and provides a factory for the state manager based off of the config.

FnMetadata is stored within the queue for retrieving.

GuaranteedCapacity represents an account with guaranteed capacity.

QueueItem represents an individually queued work scheduled for some time in the future.

QueuePartition represents an individual queue for a workflow.

Lua represents a redis lua script.

QueueLifecycleListener represents a lifecycle listener for queue-related specifics.

ConcurrencyLimitGetter returns the fn, account, and custom limits for a given partition.

GuaranteedCapacityFinder returns the given guaranteed capacity for an account ID, or nil if the account does not have guaranteed capacity.

Opt represents an option to use when creating a redis-backed state store.

PriorityFinder returns the priority for a given queue partition.

QueueItemConcurrencyKeyLimitRefresher returns concurrency keys with current limits given a queue item.

QueueItemIndex represends a set of indexes for a given queue item.

QueueItemIndexer represents a function which generates indexes for a given queue item.

SystemConcurrencyLimitGetter returns the concurrency limits for a given system partition.