Verk.DeadSet

This module interacts with jobs in the dead set

Summary

add(job, timestamp, redis \\ Verk.Redis)
clear(redis \\ Verk.Redis)

Clears the dead set

count(redis \\ Verk.Redis)

Counts how many jobs are inside the dead set

delete_job(original_json, redis \\ Verk.Redis)

Delete the job from the dead set

key()

Redis dead set key

range(start \\ 0, stop \\ -1, redis \\ Verk.Redis)

List jobs from start to stop

Functions

add(job, timestamp, redis \\ Verk.Redis)
clear(redis \\ Verk.Redis)

Specs:

Clears the dead set

count(redis \\ Verk.Redis)

Specs:

  • count(GenServer.Server) :: integer

Counts how many jobs are inside the dead set

delete_job(original_json, redis \\ Verk.Redis)

Specs:

  • delete_job(%Verk.Job{args: term, class: term, enqueued_at: term, error_backtrace: term, error_message: term, failed_at: term, finished_at: term, jid: term, original_json: term, queue: term, retried_at: term, retry_count: term} | String.t, GenServer.server) :: boolean

Delete the job from the dead set

key()

Redis dead set key

range(start \\ 0, stop \\ -1, redis \\ Verk.Redis)

Specs:

List jobs from start to stop