class Mosquito::RedisBackend

• Mosquito::RedisBackend
• Mosquito::Backend
• Reference
• Object

Extended Modules

• Mosquito::Backend::ClassMethods

Defined in:

Constant Summary

LIST_OF_QUEUES_KEY = "queues"

Log = ::Log.for(self)

Constructors

• .new(name : String | Symbol)

Class Method Summary

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

  Overload required for crystal 1.1-1.2.

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

  is this even a good idea?

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

Instance Method Summary

• #dequeue : JobRun | Nil
• #deschedule : Array(JobRun)
• #dump_dead_q : Array(String)
• #dump_pending_q : Array(String)
• #dump_scheduled_q : Array(String)
• #dump_waiting_q : Array(String)
• #enqueue(job_run : JobRun) : JobRun

  from queue.cr

• #finish(job_run : JobRun)
• #flush : Nil
• #redis
• #schedule(job_run : JobRun, at scheduled_time : Time) : JobRun
• #scheduled_job_run_time(job_run : JobRun) : String | Nil
• #size(include_dead = true) : Int64
• #terminate(job_run : JobRun)

Constructor Detail

Class Method Detail

Instance Method Detail