class PlaceOS::Driver::Queue

• PlaceOS::Driver::Queue
• Reference
• Object

Defined in:

placeos-driver/queue.cr

Instance Method Summary

• #add(priority = @priority, timeout = @timeout, retries = @retries, wait = @wait, name = nil, delay = @delay, clear_queue = false, &callback : Task -> Nil)

  adds a task callback to the queue

• #clear(abort_current = false)

  removes all jobs currently in the queue

• #current : Task | Nil
• #delay : Time::Span | Nil
• #delay=(delay : Time::Span | Nil)
• #logger : ::Log
• #online : Bool
• #online=(state : Bool)
• #previous : Task | Nil
• #priority : Int32

  for modifying defaults

• #priority=(priority : Int32)

  for modifying defaults

• #retries : Int32
• #retries=(retries : Int32)
• #retry_bonus : Int32
• #retry_bonus=(retry_bonus : Int32)
• #set_connected(state)

  A helper method for setting the connected state, without effecting queue processing.

• #terminated : Bool
• #timeout : Time::Span
• #timeout=(timeout : Time::Span)
• #wait : Bool
• #wait=(wait : Bool)

Instance Method Detail