class Mosquito::Runners::QueueList

Overview

QueueList handles searching the redis keyspace for named queues.

Included Modules

Defined in:

mosquito/runners/queue_list.cr

Constant Summary

Log = ::Log.for(self)

Constructors

Instance Method Summary

Instance methods inherited from module Mosquito::Runners::IdleWait

with_idle_wait(idle_wait : Time::Span, &) with_idle_wait

Instance methods inherited from module Mosquito::Runnable

dead? : Bool dead?, each_run : Nil each_run, fiber : Fiber | Nil fiber, my_name : String my_name, post_run : Nil post_run, pre_run : Nil pre_run, run run, runnable_name : String runnable_name, state : State state, stop : Channel(Bool) stop

Instance methods inherited from module Mosquito::Runners::RunAtMost

execution_timestamps execution_timestamps

Constructor Detail

def self.new #

Instance Method Detail

def each(*args, **options) #

def each(*args, **options, &) #

def each_run : Nil #
Description copied from module Mosquito::Runnable

Implementation of what this Runnable should do on each cycle.

Take care that @state is #running? at the end of the method unless it is finished and should exit.


def queues : Array(Queue) #

def runnable_name : String #
Description copied from module Mosquito::Runnable

Used to print a pretty name for logging.