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