class

Mosquito::Runners::Coordinator

Inherits Reference < Object

primer? loader? scheduler

Constants

LockTTL = 10.seconds
Log = ::Log.for(self)

Constructors

new(queue_list : Mosquito::Runners::QueueList)
Source

Instance methods

enqueue_delayed_jobs
Source
enqueue_periodic_jobs
Source
instance_id
Source
lock_key
Source
only_if_coordinator
Source
queue_list
Source
runnable_name
Source
schedule
Source