class Mosquito::Runners::QueueList
- Mosquito::Runners::QueueList
- Reference
- Object
Overview
QueueList handles searching the redis keyspace for named queues.
Included Modules
Defined in:
mosquito/runners/queue_list.crConstructors
Instance Method Summary
- #each(*args, **options)
- #each(*args, **options, &)
-
#each_run : Nil
Implementation of what this Runnable should do on each cycle.
- #queues : Array(Queue)
-
#runnable_name : String
Used to print a pretty name for logging.
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
Instance Method Detail
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 runnable_name : String
#
Description copied from module Mosquito::Runnable
Used to print a pretty name for logging.