class JoobQ::Queue(T)

• JoobQ::Queue(T)
• JoobQ::BaseQueue
• Reference
• Object

Overview

The Queue class now focuses on queue operations

Defined in:

joobq/queue.cr

Constructors

• .new(name : String, total_workers : Int32, throttle_limit : NamedTuple(limit: Int32, period: Time::Span) | Nil = nil)

Instance Method Summary

• #add(job : String)
• #add(job : T)
• #clear
• #delete_job(job : Job)
• #info
• #metrics : Metrics
• #name : String
• #next_job
• #running? : Bool
• #running_workers : Int32
• #size : Int64
• #start
• #status : String
• #stop!
• #store : Store
• #throttle_limit : NamedTuple(limit: Int32, period: Time::Span) | Nil
• #total_workers : Int32
• #worker_manager : WorkerManager(T)

Constructor Detail

Instance Method Detail