ActiveKey returns a redis key for the active tasks.

AggregationSetKey returns a redis key used for an aggregation set.

AllAggregationSets returns a redis key used to store all aggregation sets (set of tasks staged to be aggregated) in a given queue.

AllGroups return a redis key used to store all group keys used in a given queue.

ArchivedKey returns a redis key for the archived tasks.

DecodeMessage unmarshals the given bytes and returns a decoded task message.

DecodeSchedulerEnqueueEvent unmarshals the given bytes and returns a decoded SchedulerEnqueueEvent.

DecodeSchedulerEntry unmarshals the given bytes and returns a decoded SchedulerEntry.

DecodeServerInfo decodes the given bytes into ServerInfo.

DecodeWorkerInfo decodes the given bytes into WorkerInfo.

EncodeMessage marshals the given task message and returns an encoded bytes.

EncodeSchedulerEnqueueEvent marshals the given event and returns an encoded bytes.

EncodeSchedulerEntry marshals the given entry and returns an encoded bytes.

EncodeServerInfo marshals the given ServerInfo and returns the encoded bytes.

EncodeWorkerInfo marshals the given WorkerInfo and returns the encoded bytes.

FailedKey returns a redis key for failure count for the given day for the queue.

FailedTotalKey returns a redis key for total failure count for the given queue.

GroupKey returns a redis key used to group tasks belong in the same group.

GroupKeyPrefix returns a prefix for group key.

LeaseKey returns a redis key for the lease.

NewCancelations returns a Cancelations instance.

PausedKey returns a redis key to indicate that the given queue is paused.

PendingKey returns a redis key for the given queue name.

ProcessedKey returns a redis key for processed count for the given day for the queue.

ProcessedTotalKey returns a redis key for total processed count for the given queue.

QueueKeyPrefix returns a prefix for all keys in the given queue.

RetryKey returns a redis key for the retry tasks.

ScheduledKey returns a redis key for the scheduled tasks.

SchedulerEntriesKey returns a redis key for the scheduler entries given scheduler ID.

SchedulerHistoryKey returns a redis key for the scheduler's history for the given entry.

ServerInfoKey returns a redis key for process info.

TaskKey returns a redis key for the given task message.

TaskKeyPrefix returns a prefix for task key.

UniqueKey returns a redis key with the given type, payload, and queue name.

ValidateQueueName validates a given qname to be used as a queue name.

WorkersKey returns a redis key for the workers given hostname, pid, and server ID.

DefaultQueueName is the queue name used if none are specified by user.

describes a state where task is waiting in a group to be aggregated.

Version of asynq library and CLI.

DefaultQueue is the redis key for the default queue.

GlobalPrefix is the prefix for all redis keys used by asynq.

Cancelations is a collection that holds cancel functions for all active tasks.

Lease is a time bound lease for worker to process task.

SchedulerEnqueueEvent holds information about an enqueue event by a scheduler.

SchedulerEntry holds information about a periodic task registered with a scheduler.

ServerInfo holds information about a running server.

TaskInfo describes a task message and its metadata.

TaskMessage is the internal representation of a task with additional metadata fields.

WorkerInfo holds information about a running worker.

Z represents sorted set member.

Broker is a message broker that supports operations to manage task queues.

TaskState denotes the state of a task.