class Mosquito::Observability::Queue

Included Modules

Defined in:

mosquito/api/queue.cr

Constructors

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(queue : Mosquito::Queue) #

Instance Method Detail

def dequeued(job_run : JobRun) #

def enqueued(job_run : JobRun, at execute_time : Time) #

def enqueued(job_run : JobRun) #

def log : ::Log #

def publish_context : PublishContext #