CreateQueue for name with provided handler and exemplar.

GetManager returns a Manager and initializes one as singleton if there's none yet.

IsErrInvalidConfiguration checks if an error is an ErrInvalidConfiguration.

NewChannelQueue creates a memory channel queue.

NewDummyQueue creates a new DummyQueue.

NewLevelQueue creates a ledis local queue.

NewPersistableChannelQueue creates a wrapped batched channel queue with persistable level queue backend when shutting down This differs from a wrapped queue in that the persistent queue is only used to persist at shutdown/terminate.

NewQueue takes a queue Type, HandlerFunc, some options and possibly an exemplar and returns a Queue or an error.

NewRedisQueue creates single redis or cluster redis queue.

NewWorkerPool creates a new worker pool.

NewWrappedQueue will attempt to create a queue of the provided type, but if there is a problem creating this queue it will instead create a WrappedQueue with delayed startup of the queue instead and a channel which will be redirected to the queue.

RegisteredTypes provides the list of requested types of queues.

RegisteredTypesAsString provides the list of requested types of queues.

ChannelQueueType is the type for channel queue.

DummyQueueType is the type for the dummy queue.

LevelQueueType is the type for level queue.

PersistableChannelQueueType is the type for persistable queue.

RedisQueueType is the type for redis queue.

WrappedQueueType is the type for a wrapped delayed starting queue.

ChannelQueue implements Queue A channel queue is not persistable and does not shutdown or terminate cleanly It is basically a very thin wrapper around a WorkerPool.

ChannelQueueConfiguration is the configuration for a ChannelQueue.

DummyQueue represents an empty queue.

ErrInvalidConfiguration is called when there is invalid configuration for a queue.

LevelQueue implements a disk library queue.

LevelQueueConfiguration is the configuration for a LevelQueue.

ManagedQueue represents a working queue with a Pool of workers.

Manager is a queue manager.

PersistableChannelQueue wraps a channel queue and level queue together The disk level queue will be used to store data at shutdown and terminate - and will be restored on start up.

PersistableChannelQueueConfiguration is the configuration for a PersistableChannelQueue.

PoolWorkers represents a group of workers working on a queue.

RedisQueue redis queue.

RedisQueueConfiguration is the configuration for the redis queue.

WorkerPool represent a dynamically growable worker pool for a provided handler function.

WorkerPoolConfiguration is the basic configuration for a WorkerPool.

WrappedQueue wraps a delayed starting queue.

WrappedQueueConfiguration is the configuration for a WrappedQueue.

Data defines an type of queuable data.

Flushable represents a pool or queue that is flushable.

ManagedPool is a simple interface to get certain details from a worker pool.

Named represents a queue with a name.

Queue defines an interface of a queue-like item Queues will handle their own contents in the Run method.

Shutdownable represents a queue that can be shutdown.

HandlerFunc is a function that takes a variable amount of data and processes it.

ManagedQueueList implements the sort.Interface.

NewQueueFunc is a function that creates a queue.

PoolWorkersList implements the sort.Interface for PoolWorkers.

Type is a type of Queue.