class Mosquito::RedisBackend

Extended Modules

Mosquito::Backend::ClassMethods

Defined in:

mosquito/redis_backend.cr

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)

Instance methods inherited from class `Mosquito::Backend`

, , , , , , , , , , , , , , , , , , , , ,

Constructor methods inherited from class `Mosquito::Backend`

Class methods inherited from class `Mosquito::Backend`

, ,

Constructor Detail

def self.new(name : String | Symbol) #

Class Method Detail

def self.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).")]

def self.delete(key : String, in ttl : Int64 = 0) : Nil #

def self.delete(key : String, in ttl : Time::Span) : Nil #

def self.expires_in(key : String) : Int64 #

def self.flush : Nil #

is this even a good idea?

def self.get(key : String, field : String) : String | Nil #

def self.increment(key : String, field : String, by value : Int32) : Int64 #

def self.increment(key : String, field : String) : Int64 #

def self.list_queues : Array(String) #

def self.list_runners : Array(String) #

def self.lock?(key : String, value : String, ttl : Time::Span) : Bool #

def self.redis #

def self.remove_matching_key(*, keys = [] of String, args = [] of String, loadscripts = true) #

def self.retrieve(key : String) : Hash(String, String) #

def self.set(key : String, field : String, value : String) : String #

def self.store(key : String, value : Hash(String, String)) : Nil #

def self.unlock(key : String, value : String) : Nil #

Instance Method Detail

def dequeue : JobRun | Nil #

def deschedule : Array(JobRun) #

def dump_dead_q : Array(String) #

def dump_pending_q : Array(String) #

def dump_scheduled_q : Array(String) #

def dump_waiting_q : Array(String) #

def enqueue(job_run : JobRun) : JobRun #

Description copied from class Mosquito::Backend

from queue.cr

def finish(job_run : JobRun) #

def flush : Nil #

def redis #

def schedule(job_run : JobRun, at scheduled_time : Time) : JobRun #

def scheduled_job_run_time(job_run : JobRun) : String | Nil #

def size(include_dead = true) : Int64 #

def terminate(job_run : JobRun) #

mosquito