Verk v1.7.3

Verk.QueueManager (Verk v1.7.3) View Source

QueueManager interacts with redis to dequeue jobs from the specified queue.

Link to this section Summary

Functions

ack(queue_manager, job)

Acknowledges that a job was processed.

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

dequeue(queue_manager, n, timeout \\ 5000)

Pop a job from the assigned queue and reply with it if not empty.

enqueue_inprogress(queue_manager)

Enqueues inprogress jobs back to the queue.

init(list)

Connects to redis.

malformed(queue_manager, job)

Removes a malformed job from the inprogress queue.

name(queue)

Returns the atom that represents the QueueManager of the queue.

retry(queue_manager, job, exception, stacktrace, timeout \\ 5000)

Add job to be retried in the assigned queue.

Link to this section Functions

Link to this function

ack(queue_manager, job)

View Source

Acknowledges that a job was processed.

Link to this function

child_spec(init_arg)

View Source

Returns a specification to start this module under a supervisor.

See Supervisor.

Link to this function

dequeue(queue_manager, n, timeout \\ 5000)

View Source

Pop a job from the assigned queue and reply with it if not empty.

Link to this function

enqueue_inprogress(queue_manager)

View Source

Enqueues inprogress jobs back to the queue.

Link to this function

init(list)

View Source

Connects to redis.

Link to this function

malformed(queue_manager, job)

View Source

Removes a malformed job from the inprogress queue.

Link to this function

name(queue)

View Source

Specs

name(binary() | atom()) :: atom()

Returns the atom that represents the QueueManager of the queue.

Link to this function

retry(queue_manager, job, exception, stacktrace, timeout \\ 5000)

View Source

Add job to be retried in the assigned queue.