class

Mosquito::RedisBackend

Inherits Mosquito::Backend < Reference < Object

Constants

LIST_OF_QUEUES_KEY = "queues"
Log = ::Log.for(self)

Constructors

new(name : String | Symbol)
Source

Class methods

delete(key : String, in ttl : Int32 = 0) : Nil

Overload required for crystal 1.1-1.2. Soft Deprecation isn't shown, but it's here so this will get cleaned up at some point. @[Deprecated("To be removed when support for 1.1 is dropped. See RedisBackend.delete(String, Int64).")]

Source
delete(key : String, in ttl : Int64 = 0) : Nil
Source
delete(key : String, in ttl : Time::Span) : Nil
Source
expires_in(key : String) : Int64
Source
flush

is this even a good idea?

Source
get(key : String, field : String) : String | Nil
Source
increment(key : String, field : String, by value : Int32) : Int64
Source
increment(key : String, field : String) : Int64
Source
list_queues
Source
list_runners
Source
lock?(key : String, value : String, ttl : Time::Span) : Bool
Source
redis
Source
remove_matching_key(*, keys = [] of String, args = [] of String, loadscripts = true)
Source
retrieve(key : String) : Hash(String, String)
Source
set(key : String, field : String, value : String) : String
Source
store(key : String, value : Hash(String, String)) : Nil
Source
unlock(key : String, value : String) : Nil
Source

Instance methods

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
finish(job_run : JobRun)
Source
flush
Source
redis
Source
schedule(job_run : JobRun, at scheduled_time : Time) : JobRun
Source
scheduled_job_run_time(job_run : JobRun) : String | Nil
Source
size(include_dead = true) : Int64
Source
terminate(job_run : JobRun)
Source