exq v0.13.0 Exq.Enqueuer

Enqueuer

Link to this section Summary

Functions

enqueue(pid, queue, worker, args)

Enqueue a job immediately

enqueue(pid, from, queue, worker, args)

enqueue(pid, from, queue, worker, args, options)

enqueue_at(pid, queue, time, worker, args)

Schedule a job to be enqueued at a specific time in the future

enqueue_at(pid, from, queue, time, worker, args)

enqueue_at(pid, from, queue, time, worker, args, options)

enqueue_in(pid, queue, offset, worker, args)

Schedule a job to be enqueued at in the future given by offset in milliseconds

enqueue_in(pid, from, queue, offset, worker, args)

enqueue_in(pid, from, queue, offset, worker, args, options)

start_link(opts \\ [])

Link to this section Functions

enqueue(pid, queue, worker, args)

Enqueue a job immediately.

Expected args:

pid - PID for Exq Manager or Enqueuer to handle this
queue - Name of queue to use
worker - Worker module to target
args - Array of args to send to worker
options - job options, for example [max_retries: Integer]

Returns:

{:ok, jid} if the job was enqueued successfully, with jid = Job ID.
{:error, reason} if there was an error enqueueing job

enqueue(pid, from, queue, worker, args)

enqueue(pid, from, queue, worker, args, options)

enqueue_at(pid, queue, time, worker, args)

Schedule a job to be enqueued at a specific time in the future.

Expected args:

pid - PID for Exq Manager or Enqueuer to handle this
queue - name of queue to use
time - Time to enqueue
worker - Worker module to target
args - Array of args to send to worker
options - job options, for example [max_retries: Integer]

enqueue_at(pid, from, queue, time, worker, args)

enqueue_at(pid, from, queue, time, worker, args, options)

enqueue_in(pid, queue, offset, worker, args)

Schedule a job to be enqueued at in the future given by offset in milliseconds.

Expected args:

pid - PID for Exq Manager or Enqueuer to handle this
queue - Name of queue to use
offset - Offset in seconds in the future to enqueue
worker - Worker module to target
args - Array of args to send to worker
options - job options, for example [max_retries: Integer]

enqueue_in(pid, from, queue, offset, worker, args)

enqueue_in(pid, from, queue, offset, worker, args, options)

start_link(opts \\ [])