class Mosquito::Runners::Coordinator

Overview

primer? loader? scheduler

Defined in:

mosquito/runners/coordinator.cr

Constant Summary

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

Constructors

Instance Method Summary

Constructor Detail

def self.new(queue_list : Mosquito::Runners::QueueList) #

Instance Method Detail

def enqueue_delayed_jobs #

def enqueue_periodic_jobs #

def instance_id : String #

def lock_key : String #

def only_if_coordinator(&) : Nil #

def queue_list : QueueList #

def runnable_name : String #

def schedule : Nil #