class

Mosquito::Backend

Inherits Reference < Object

Constants

KEY_PREFIX = {"mosquito"}
QUEUES = ["waiting", "scheduled", "pending", "dead"] of ::String

Constructors

new(name : String | Symbol)
Source

Class methods

build_key(*parts)
Source
named(name)
Source
search_queues
Source

Instance methods

build_key(*parts)
Source
dead_q
Source
delete(key : String, in ttl = 0) : Nil
Source
dequeue
Source
deschedule
Source
dump_dead_q
Source
dump_pending_q
Source
dump_scheduled_q
Source
dump_waiting_q
Source
enqueue(job_run : JobRun) : JobRun

from queue.cr

Source
expires_in(key : String) : Int64
Source
finish(job_run : JobRun)
Source
flush
Source
pending_q
Source
retrieve(key : String) : Hash(String, String)
Source
schedule(job_run : JobRun, at scheduled_time : Time) : JobRun
Source
scheduled_job_run_time(job_run : JobRun) : String | Nil
Source
scheduled_q
Source
size(include_dead : Bool = true) : Int64
Source
store(key : String, value : Hash(String, String)) : Nil
Source
terminate(job_run : JobRun)
Source
waiting_q
Source

Nested types