class Beanpool

# 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

# File lib/beanpool.rb, line 21
def close
  @connections.close
end

# File lib/beanpool.rb, line 17
def get(timeout = nil, tube_name = 'default')
  @connections.get_job_from_tube(timeout, tube_name)
end

# File lib/beanpool.rb, line 40
def get_ready_by_tube(name)
  @connections.stats(name, :current_jobs_ready)
end

# File lib/beanpool.rb, line 36
def get_stat_by_tube(tube_name, stat_name)
  @connections.stats(tube_name, stat_name)
end

# File lib/beanpool.rb, line 13
def put(body, options)
  @connections.put_job_to_tube(body, options)
end

# File lib/beanpool.rb, line 44
def size
  @connections.stats('default', :current_jobs_ready)
end

# File lib/beanpool.rb, line 25
def stats(tube_name)
  @connections.all_stats(tube_name)
rescue => ex
  BlitlineLogger.log(ex)
  return {}
end

# File lib/beanpool.rb, line 32
def use_tube(tube_name)
  @connections.use_tube(tube_name)
end