class Qube::Queue

Attributes

statistics[R]
tubes[R]

Public Class Methods

new() click to toggle source
# File lib/qube/model/queue.rb, line 6
def initialize
  @config     = Qube.config
  @client     = Client.new
  @tubes      = nil
  @statistics = nil
end

Public Instance Methods

create_tube(options = {}) click to toggle source
# File lib/qube/model/queue.rb, line 26
def create_tube(options = {})
  Tube.new(options)
end
delete_tube(name) click to toggle source
# File lib/qube/model/queue.rb, line 34
def delete_tube(name)
  @client.delete("tubes/#{name}")&.body
end
enqueue(tube, task, options = {}) click to toggle source
# File lib/qube/model/queue.rb, line 13
def enqueue(tube, task, options = {})
  response = @client.post("tubes/#{tube}", tube: tube, task: task, options: options)
  response.code == 200
end
tube_exist?(name) click to toggle source
# File lib/qube/model/queue.rb, line 30
def tube_exist?(name)
  tubes.include?(name)
end