class Mosquito::Observability::Executor

Included Modules

Defined in:

mosquito/api/executor.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

Constructor Detail

def self.new(executor : Mosquito::Runners::Executor) #

Class Method Detail

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

Instance Method Detail

def execute(job_run : JobRun, from_queue : Queue, &) #

def heartbeat!(*args, **options) #

def heartbeat!(*args, **options, &) #

def log_failure_message(job_run : JobRun, duration : Time::Span) #

def log_success_message(job_run : JobRun, duration : Time::Span) #