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) #

[View source]

Instance Method Detail

def enqueue_delayed_jobs #

[View source]
def enqueue_periodic_jobs #

[View source]
def instance_id : String #

[View source]
def lock_key : String #

[View source]
def only_if_coordinator(&) : Nil #

[View source]
def queue_list : QueueList #

[View source]
def runnable_name : String #

[View source]
def schedule : Nil #

[View source]