class Mosquito::RedisBackend::Queue

Defined in:

mosquito/redis_backend.cr
ye_olde_redis.cr

Constructors

Instance Method Summary

Instance methods inherited from class Mosquito::Backend::Queue

backend : Backend backend, dead_size : Int64 dead_size, dequeue : JobRun | Nil dequeue, deschedule : Array(JobRun) deschedule, enqueue(job_run : JobRun) : JobRun enqueue, finish(job_run : JobRun) finish, flush : Nil flush, list_dead : Array(String) list_dead, list_pending : Array(String) list_pending, list_scheduled : Array(String) list_scheduled, list_waiting : Array(String) list_waiting, pause(duration : Time::Span | Nil = nil) : Nil pause, paused? : Bool paused?, pending_size : Int64 pending_size, resume : Nil resume, schedule(job_run : JobRun, at scheduled_time : Time) : JobRun schedule, scheduled_job_run_time(job_run : JobRun) : Time | Nil scheduled_job_run_time, scheduled_size : Int64 scheduled_size, size(include_dead : Bool = true) : Int64 size, terminate(job_run : JobRun) terminate, undequeue : JobRun | Nil undequeue, waiting_size : Int64 waiting_size

Constructor methods inherited from class Mosquito::Backend::Queue

new(backend : Mosquito::Backend, name : String) new

Constructor Detail

def self.new(backend : RedisBackend, name : String) #

Instance Method Detail

def dead_size : Int64 #

def dequeue : JobRun | Nil #

def deschedule : Array(JobRun) #

def enqueue(job_run : JobRun) : JobRun #
Description copied from class Mosquito::Backend::Queue

Queue operations


def finish(job_run : JobRun) #

def flush : Nil #

def list_dead : Array(String) #

def list_pending : Array(String) #

def list_scheduled : Array(String) #

def list_waiting : Array(String) #

def pause(duration : Time::Span | Nil = nil) : Nil #
Description copied from class Mosquito::Backend::Queue

Pause this queue so that #dequeue returns nil until it is resumed or the optional duration expires.


def paused? : Bool #

def pending_size : Int64 #

def resume : Nil #
Description copied from class Mosquito::Backend::Queue

Resume a paused queue, allowing dequeue to proceed.


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

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

def scheduled_size : Int64 #

def size(include_dead = true) : Int64 #

def terminate(job_run : JobRun) #

def undequeue : JobRun | Nil #

def waiting_size : Int64 #