class Mosquito::Observability::Overseer

Included Modules

Defined in:

mosquito/api/overseer.cr

Constructors

Class Method Summary

Instance Method Summary

Instance methods inherited from module Mosquito::Observability::Publisher

publish(data : NamedTuple) publish, publish_context : PublishContext publish_context

Macros inherited from module Mosquito::Observability::Publisher

metrics(&block) metrics

Constructor Detail

def self.new(overseer : Runners::Overseer) #

Class Method Detail

def self.metadata_key(instance_id : String) : String #

Instance Method Detail

def channels_closed #

def executor_created(executor : Runners::Executor) : Nil #

def executor_died(executor : Runners::Executor) : Nil #

def heartbeat #

def instance_id : String #

def metadata : Metadata #

def orphaned_jobs_recovered(total : Int32) #

def queue_list_died #

def recovered_job_from_executor(job_run : JobRun, executor : Runners::Executor) #

def recovered_orphaned_job(job_run : JobRun, overseer_id : String) #

def shutting_down #

def starting #

def stopped #

def stopping #

def update_executor_list(executors : Array(Runners::Executor)) : Nil #

def waiting_for_queue_list #