Bolt

v0.1.9

Bolt v0.1.9 Bolt.JobStore View Source

Link to this section Summary

Functions

add(queue_name, job_params)
backup_job(conn, queue_name, job_id)
failed(queue_name, job_id, error)
failed_count(queue_name)

Get the number of failed jobs for this queue

failed_details(queue_name, job_id)

Gets the details of a given failed job id

failed_list(queue_name)

Get the latest set of failed jobs for this queue

finish(queue_name, job_id)
handle_call(msg, from, state)

GenServer handler for getting the details of a given failed job

remaining_count(queue_name)
restore_backup(conn, queue_name, job_id)

Moves the backed up job into the queue to be processed. This is called once on start for each of the unfinished jobs

resume_inprogress(queue_name)
start(queue_name)
start_link()

Link to this section Functions

Link to this function add(queue_name, job_params) View Source
Link to this function backup_job(conn, queue_name, job_id) View Source
Link to this function failed(queue_name, job_id, error) View Source
Link to this function failed_count(queue_name) View Source

Get the number of failed jobs for this queue.

Link to this function failed_details(queue_name, job_id) View Source

Gets the details of a given failed job id.

Link to this function failed_list(queue_name) View Source

Get the latest set of failed jobs for this queue.

Link to this function finish(queue_name, job_id) View Source
Link to this function handle_call(msg, from, state) View Source

GenServer handler for getting the details of a given failed job

Link to this function remaining_count(queue_name) View Source
Link to this function restore_backup(conn, queue_name, job_id) View Source

Moves the backed up job into the queue to be processed. This is called once on start for each of the unfinished jobs.

Link to this function resume_inprogress(queue_name) View Source