class Mosquito::Runners::QueueList

Overview

QueueList handles searching the redis keyspace for named queues.

Included Modules

Defined in:

mosquito/runners/queue_list.cr

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(*, 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

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 notify_released(job_run : JobRun, queue : Queue) : Nil #

Notifies the resource gate for the given queue that a job has finished, allowing it to update internal bookkeeping.


def observer : Observability::QueueList #

def queues : Array(Queue) #

Returns the queues eligible for dequeuing: discovered queues filtered by any configured resource gates.


def resource_gates : Hash(String, ResourceGate) #

Maps queue names to resource gates. Queues not present in this mapping are always eligible for dequeuing.


def resource_gates=(resource_gates : Hash(String, ResourceGate)) #

Maps queue names to resource gates. Queues not present in this mapping are always eligible for dequeuing.


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

Used to print a pretty name for logging.