class Beanpool
Constants
- VERSION
Attributes
connections[R]
Public Class Methods
new(ip_array, debug = false)
click to toggle source
# File lib/beanpool.rb, line 8 def initialize(ip_array, debug = false) raise 'Beanpool must be initialized with an array of IP addresses' unless ip_array.is_a?(Array) && !ip_array.empty? @connections = Beanpool::Connections.new(ip_array, debug) end
Public Instance Methods
close()
click to toggle source
# File lib/beanpool.rb, line 21 def close @connections.close end
get(timeout = nil, tube_name = 'default')
click to toggle source
# File lib/beanpool.rb, line 17 def get(timeout = nil, tube_name = 'default') @connections.get_job_from_tube(timeout, tube_name) end
get_ready_by_tube(name)
click to toggle source
# File lib/beanpool.rb, line 40 def get_ready_by_tube(name) @connections.stats(name, :current_jobs_ready) end
get_stat_by_tube(tube_name, stat_name)
click to toggle source
# File lib/beanpool.rb, line 36 def get_stat_by_tube(tube_name, stat_name) @connections.stats(tube_name, stat_name) end
put(body, options)
click to toggle source
# File lib/beanpool.rb, line 13 def put(body, options) @connections.put_job_to_tube(body, options) end
size()
click to toggle source
# File lib/beanpool.rb, line 44 def size @connections.stats('default', :current_jobs_ready) end
stats(tube_name)
click to toggle source
# File lib/beanpool.rb, line 25 def stats(tube_name) @connections.all_stats(tube_name) rescue => ex BlitlineLogger.log(ex) return {} end
use_tube(tube_name)
click to toggle source
# File lib/beanpool.rb, line 32 def use_tube(tube_name) @connections.use_tube(tube_name) end