Open Sidebar
Close Sidebar
mosquito
2.0.0
Mosquito
Api
Executor
JobRun
Overseer
PeriodicJob
Queue
Backend
BroadcastMessage
Queue
Base
Configuration
DequeueAdapter
DoubleRun
Id
IrretrievableParameter
Job
State
JobFailed
JobRun
KeyBuilder
Metadata
Observability
Executor
Overseer
PeriodicJob
Publisher
PublishContext
Context
Queue
QueueList
OpenGate
PeriodicJob
PeriodicJobRun
Queue
QueuedJob
RateLimiter
ClassMethods
RedisBackend
Queue
ResourceGate
Runnable
State
Runner
Runners
Coordinator
Executor
IdleWait
Overseer
QueueList
RunAtMost
ScheduledJob
Scripts
Serializers
Primitives
ShuffleDequeueAdapter
TestBackend
EnqueuedJob
Queue
ThresholdGate
UniqueJob
ClassMethods
WeightedDequeueAdapter
WorkUnit
class
Mosquito::
Observability::
PeriodicJob
Mosquito::Observability::PeriodicJob
Reference
Object
Included Modules
Mosquito::Observability::Publisher
Defined in:
mosquito/api/periodic_job.cr
Constructors
.new
(periodic_job_run : Mosquito::PeriodicJobRun)
Instance Method Summary
#enqueued
(at time : Time)
#log
: ::Log
#publish_context
: PublishContext
#skipped
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
(periodic_job_run :
Mosquito::PeriodicJobRun
)
#
Instance Method Detail
def
enqueued
(at time : Time)
#
def
log
: ::Log
#
def
publish_context
:
PublishContext
#
def
skipped
#