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.
- #observer : Observability::QueueList
- #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(*, spawn spawn_fiber = true)
run,
runnable_name : String
runnable_name,
state : State
state,
stop(wait_group : WaitGroup = WaitGroup.new(1)) : WaitGroup
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.