exq v0.13.2 Exq.Redis.JobQueue
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
Link to this section Functions
Link to this function
backup_queue_key(namespace, node_id, queue)
Link to this function
delete_queue(redis, namespace, queue)
Link to this function
dequeue(redis, namespace, node_id, queues)
Dequeue jobs for available queues
Link to this function
enqueue(redis, namespace, job_serialized)
Link to this function
enqueue(redis, namespace, queue, job_serialized)
Link to this function
enqueue(redis, namespace, queue, worker, args, options)
Link to this function
enqueue_at(redis, namespace, queue, time, worker, args, options)
Link to this function
enqueue_in(redis, namespace, queue, offset, worker, args, options)
Link to this function
enqueue_job_at(redis, namespace, job_serialized, jid, time, scheduled_queue)
Link to this function
fail_job(redis, namespace, job, error)
Link to this function
failed(redis, namespace)
Link to this function
failed_queue_key(namespace)
Link to this function
failed_size(redis, namespace)
Link to this function
find_job(redis, namespace, jid, queue)
Find a current job by job id (but do not pop it)
Link to this function
find_job(redis, namespace, jid, queue, convert)
Link to this function
full_key(namespace, key)
Link to this function
jobs(redis, namespace)
Link to this function
jobs(redis, namespace, queue)
Link to this function
list_queues(redis, namespace)
Link to this function
queue_key(namespace, queue)
Link to this function
queue_size(redis, namespace)
Link to this function
queue_size(redis, namespace, queue)
Link to this function
re_enqueue_backup(redis, namespace, node_id, queue)
Link to this function
remove_job(redis, namespace, queue, jid)
Link to this function
remove_job_from_backup(redis, namespace, node_id, queue, job_serialized)
Link to this function
remove_retry(redis, namespace, jid)
Link to this function
remove_scheduled(redis, namespace, jid)
Link to this function
retry_job(redis, namespace, job)
Link to this function
retry_job(redis, namespace, job, retry_count, error)
Link to this function
retry_or_fail_job(redis, namespace, job, error)
Link to this function
retry_queue_key(namespace)
Link to this function
retry_size(redis, namespace)
Link to this function
schedule_queues(namespace)
Link to this function
scheduled_jobs(redis, namespace, queue)
Link to this function
scheduled_jobs_with_scores(redis, namespace, queue)
Link to this function
scheduled_queue_key(namespace)
Link to this function
scheduled_size(redis, namespace)
Link to this function
scheduler_dequeue(redis, namespace)
Link to this function
scheduler_dequeue(redis, namespace, max_score)
Link to this function
scheduler_dequeue_requeue(list, redis, namespace, schedule_queue, count)
Link to this function
search_jobs(jobs_serialized, jid)
Link to this function
search_jobs(jobs_serialized, jid, bool)
Link to this function
to_job_serialized(queue, worker, args, options)
Link to this function