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
WeightedDequeueAdapter
class
Mosquito::
Observability::
QueueList
Mosquito::Observability::QueueList
Reference
Object
Defined in:
mosquito/api/queue_list.cr
Constructors
.new
(queue_list : Runners::QueueList)
Instance Method Summary
#checked_for_paused_queues
(paused : Array(Mosquito::Queue))
Constructor Detail
def self.
new
(queue_list :
Runners::QueueList
)
#
Instance Method Detail
def
checked_for_paused_queues
(paused : Array(
Mosquito::Queue
))
#