Exq.Redis.JobQueue (exq v0.15.0) View Source

The JobQueue module is the main abstraction of a job queue on top of Redis.

It provides functionality for:

  • Storing jobs in Redis
  • Fetching the next job(s) to be executed (and storing a backup of these).
  • Scheduling future jobs in Redis
  • Fetching scheduling jobs and moving them to current job list
  • Retrying or failing a job
  • Re-hydrating jobs from a backup queue

Link to this section Summary

Functions

Dequeue jobs for available queues

Find a current job by job id (but do not pop it)

Link to this section Functions

Link to this function

backup_queue_key(namespace, node_id, queue)

View Source
Link to this function

delete_queue(redis, namespace, queue)

View Source
Link to this function

dequeue(redis, namespace, node_id, queues)

View Source

Dequeue jobs for available queues

Link to this function

enqueue(redis, namespace, job_serialized)

View Source
Link to this function

enqueue(redis, namespace, queue, job_serialized)

View Source
Link to this function

enqueue(redis, namespace, queue, worker, args, options)

View Source
Link to this function

enqueue_at(redis, namespace, queue, time, worker, args, options)

View Source
Link to this function

enqueue_in(redis, namespace, queue, offset, worker, args, options)

View Source
Link to this function

enqueue_job_at(redis, namespace, job_serialized, jid, time, scheduled_queue)

View Source
Link to this function

fail_job(redis, namespace, job, error)

View Source
Link to this function

failed(redis, namespace)

View Source
Link to this function

failed_queue_key(namespace)

View Source
Link to this function

failed_size(redis, namespace)

View Source
Link to this function

find_job(redis, namespace, jid, queue)

View Source

Find a current job by job id (but do not pop it)

Link to this function

find_job(redis, namespace, jid, queue, convert)

View Source
Link to this function

full_key(namespace, key)

View Source
Link to this function

jobs(redis, namespace, queue)

View Source
Link to this function

list_queues(redis, namespace)

View Source
Link to this function

queue_key(namespace, queue)

View Source
Link to this function

queue_size(redis, namespace)

View Source
Link to this function

queue_size(redis, namespace, queue)

View Source
Link to this function

re_enqueue_backup(redis, namespace, node_id, queue)

View Source
Link to this function

remove_job(redis, namespace, queue, jid)

View Source
Link to this function

remove_job_from_backup(redis, namespace, node_id, queue, job_serialized)

View Source
Link to this function

remove_retry(redis, namespace, jid)

View Source
Link to this function

remove_scheduled(redis, namespace, jid)

View Source
Link to this function

retry_job(redis, namespace, job)

View Source
Link to this function

retry_job(redis, namespace, job, retry_count, error)

View Source
Link to this function

retry_or_fail_job(redis, namespace, job, error)

View Source
Link to this function

retry_queue_key(namespace)

View Source
Link to this function

retry_size(redis, namespace)

View Source
Link to this function

schedule_queues(namespace)

View Source
Link to this function

scheduled_jobs(redis, namespace, queue)

View Source
Link to this function

scheduled_jobs_with_scores(redis, namespace, queue)

View Source
Link to this function

scheduled_queue_key(namespace)

View Source
Link to this function

scheduled_size(redis, namespace)

View Source
Link to this function

scheduler_dequeue(redis, namespace)

View Source
Link to this function

scheduler_dequeue(redis, namespace, max_score)

View Source
Link to this function

search_jobs(jobs_serialized, jid)

View Source
Link to this function

search_jobs(jobs_serialized, jid, bool)

View Source
Link to this function

to_job_serialized(queue, worker, args, options)

View Source
Link to this function

to_job_serialized(queue, worker, args, options, enqueued_at)

View Source