class Mosquito::RedisBackend

Extended Modules

Defined in:

mosquito/redis_backend.cr

Constant Summary

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

Constructors

Class Method Summary

Instance Method Summary

Instance methods inherited from class Mosquito::Backend

build_key(*parts) build_key, dead_q dead_q, delete(key : String, in ttl = 0) : Nil delete, dequeue : JobRun | Nil dequeue, deschedule : Array(JobRun) deschedule, dump_dead_q : Array(String) dump_dead_q, dump_pending_q : Array(String) dump_pending_q, dump_scheduled_q : Array(String) dump_scheduled_q, dump_waiting_q : Array(String) dump_waiting_q, enqueue(job_run : JobRun) : JobRun enqueue, expires_in(key : String) : Int64 expires_in, finish(job_run : JobRun) finish, flush : Nil flush, pending_q pending_q, retrieve(key : String) : Hash(String, String) retrieve, schedule(job_run : JobRun, at scheduled_time : Time) : JobRun schedule, scheduled_job_run_time(job_run : JobRun) : String | Nil scheduled_job_run_time, scheduled_q scheduled_q, size(include_dead : Bool = true) : Int64 size, store(key : String, value : Hash(String, String)) : Nil store, terminate(job_run : JobRun) terminate, waiting_q waiting_q

Constructor methods inherited from class Mosquito::Backend

new(name : String | Symbol) new

Class methods inherited from class Mosquito::Backend

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

Constructor Detail

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

Class Method Detail

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

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

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

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

def self.expiring_list_fetch(key : String, expire_items_older_than : Time) : Array(String) #

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

TODO this should take the timestamp as an argument


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_overseers : Array(String) #

def self.list_queues : Array(String) #

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

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

def self.redis #

def self.register_overseer(id : String) : Nil #

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.subscribe(key : String) : Channel(Backend::BroadcastMessage) #

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

Instance Method Detail

def dead_size : Int64 #

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 pending_size : Int64 #

def redis #

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

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

def scheduled_size : Int64 #

def size(include_dead = true) : Int64 #

def terminate(job_run : JobRun) #

def waiting_size : Int64 #