Close closes the underlying connection

Add sents an ADDJOB command to disque, as specified by the AddRequest. Returns the job id or an error

Get gets one job from any of the given queues, or times out if timeout has elapsed without a job being available. Returns a job or an error

Execute the task on the client

Get returns a client, or an error if we could not init one

NewPool creates a new client pool, with a given redis dial function, and an initial list of ip:port addresses to try connecting to. You should call Re

NewChan creates a new disque channel objec with a given name, over a disque cluster with the given addrs. If async is true, messages are sent using di

RefreshNodes uses a HELLO call to refresh the node list in the cluster

SendChan returns a channel to which objects can be sent

Set a property in the task

Ack sends and ACKJOB command with the given job ids

Register a task handler in the worker. This shoudl

RecvChan returns a channel from which received messages can be received. Before it is called, this Chan is not receiving from the queue

Run starts the worker and makes it request jobs

RunRefreshLoop starts a goroutine that periodically refreshes the node list using HELLO

Stop stop the chan's internal send/receive loops

selectNode select a valid node by random. Currently only nodes with priority 1 are selected

Do puts the task in the queue for immediate execution, and set the task's jobId

FuncHandler takes a func and its id and converts them into a FuncTaskHandler

Hello is a handshake request with the server, returns a description of the cluster state

JobId The task's jobId

Create a new client for the given disque addrs. enqueueTimeout is the amount of time after which we fail

Create a new task with a given id

Create a new worker that runs numGoroutines concurrently, connecting to disque addrs

Qlen returns the length of a given queue

UpdateNodes explicitly sets the nodes of the pool

builds ADDJOB args

AddMulti sends multiple ADDJOB in pipeline

Close closes all pools

Delay puts the task in the queue for execution after the delay period of time. This also sets the jobId of the task

GetMulti gets <count> jobs from the given queues, or times out if timeout has elapsed without enough jobs being available. Returns a list of jobs or a

getPool returns a redis connection pool for a given address

a single worker loop

runHandler safely wraps running a single task in a handler

Ack sends and ACKJOB command with the given job ids

Add sents an ADDJOB command to disque, as specified by the AddRequest. Returns the job id or an error

AddMulti sends multiple ADDJOB in pipeline

Close closes the underlying connection

Delay executes the task, delayed for d duration

Enqueue an already existing job by jobId. This can be used for fast retries

FastAck sends a FASTACK commadn with the given job ids. See the disque docs about the difference between ACK and FASTACK

FastAck sends a FASTACK commadn with the given job ids. See the disque docs about the difference between ACK and FASTACK

Get gets one job from any of the given queues, or times out if timeout has elapsed without a job being available. Returns a job or an error

GetMulti gets <count> jobs from the given queues, or times out if timeout has elapsed without enough jobs being available. Returns a job or an error

Handle calls the underlying func to handle the task

Hello is a handshake request with the server, returns a description of the cluster state TODO: implement this

Id returns the job id. the underlying id is only settable by the client, so there is only a getter for it

Id returns the id of the handler

IsNull checks if a node is empty or not

Name returns the name of the chan

Qlen returns the length of a given queue

Set the retry timeout. This must be greater than 1. If the worker does not ACK the task in this timeout, disque will try to re-queue it

Set the task TTL - if it will not succeed after this time, disque will give up on it

Stop stops the worker from processing new tasks