Open Sidebar
Close Sidebar
mosquito
2.0.0
Mosquito
Api
Executor
JobRun
Overseer
Queue
Backend
BroadcastMessage
Queue
Base
Configuration
DequeueAdapter
DoubleRun
Id
IrretrievableParameter
Job
State
JobFailed
JobRun
KeyBuilder
Metadata
Observability
Executor
Overseer
Publisher
PublishContext
Context
Queue
QueueList
PeriodicJob
PeriodicJobRun
Queue
QueuedJob
RateLimiter
ClassMethods
RedisBackend
Queue
Runnable
State
Runner
Runners
Coordinator
Executor
IdleWait
Overseer
QueueList
RunAtMost
ScheduledJob
Scripts
Serializers
Primitives
ShuffleDequeueAdapter
TestBackend
EnqueuedJob
Queue
UniqueJob
ClassMethods
WeightedDequeueAdapter
WorkUnit
module
Mosquito::
Observability::
Publisher
Direct including types
Mosquito::Observability::Executor
Mosquito::Observability::Overseer
Mosquito::Observability::Queue
Defined in:
mosquito/api/observability/publisher.cr
Constant Summary
Log
=
::
Log
.
for
(
"mosquito.events"
)
Macro Summary
metrics
(&block)
Instance Method Summary
#publish
(data : NamedTuple)
#publish_context
: PublishContext
Macro Detail
macro
metrics
(&block)
#
Instance Method Detail
def
publish
(data : NamedTuple)
#
def
publish_context
:
PublishContext
#