class Conveyor::Orchestrator

Defined in:

orchestrator.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(configuration config : Conveyor::Configuration = CONFIG, log : Log = Log.for("conveyor")) #

[View source]

Instance Method Detail

def clear_queues! #

[View source]
def on_error(&on_error : ::Exception -> Nil) : self #

[View source]
def schedule(&) #

[View source]
def start #

[View source]
def stats #

[View source]
def stop #

[View source]