class Mosquito::Runners::Coordinator

• Mosquito::Runners::Coordinator
• Reference
• Object

Overview

primer? loader? scheduler

Defined in:

mosquito/runners/coordinator.cr

Constant Summary

LockTTL = 30.seconds

Log = ::Log.for(self)

Constructors

• .new(queue_list : Mosquito::Runners::QueueList)

Instance Method Summary

• #enqueue_delayed_jobs
• #enqueue_periodic_jobs
• #instance_id : String
• #is_leader? : Bool
• #lock_key : String
• #only_if_coordinator(&) : Nil
• #post_run : Nil
• #queue_list : QueueList
• #release_leadership_lock : Nil

  Releases the coordinator lease.

• #runnable_name : String
• #schedule : Nil

Constructor Detail

Instance Method Detail