# Functions
DecodeMessage unmarshals the given encoded string and returns a decoded task message.
EncodeMessage marshals the given task message in JSON and returns an encoded string.
FailureKey returns a redis key for failure count for the given day.
NewCancelations returns a Cancelations instance.
NewServerStatus returns a new status instance given an initial value.
ProcessedKey returns a redis key for processed count for the given day.
QueueKey returns a redis key for the given queue name.
ServerInfoKey returns a redis key for process info.
set base prefix only can set once before client or server launch.
WorkersKey returns a redis key for the workers given hostname, pid, and server ID.
# Constants
DefaultQueueName is the queue name used if none are specified by user.
StatusIdle indicates the server is in idle state.
StatusQuiet indicates the server is up but not processing new tasks.
StatusRunning indicates the servier is up and processing tasks.
StatusStopped indicates the server server has been stopped.
Version of asynq library and CLI.
# Variables
SET.
ZSET.
ZSET.
PubSub channel.
ZSET.
LIST.
LIST.
ZSET.
SET.
LIST - asynq:queues:<qname>.
ZSET.
ZSET.
# Structs
Cancelations is a collection that holds cancel functions for all in-progress tasks.
ServerInfo holds information about a running server.
ServerStatus represents status of a server.
TaskMessage is the internal representation of a task with additional metadata fields.
WorkerInfo holds information about a running worker.
Z represents sorted set member.
# Interfaces
Broker is a message broker that supports operations to manage task queues.
# Type aliases
No description provided by the author