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 : String) #

def self.new(queue : Mosquito::Queue) #

Instance Method Detail

def banished(job_run : JobRun) #

def dequeued(job_run : JobRun) #

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

def enqueued(job_run : JobRun) #

def forgotten(job_run : JobRun) #

def log : ::Log #

def name(*args, **options) #

def name(*args, **options, &) #

def paused(duration : Time::Span | Nil = nil) #

def publish_context : PublishContext #

def rescheduled(job_run : JobRun, to execute_time : Time) #

def resumed #