class HerokuAutoScale::RedisOperations

Attributes

redis_connection[R]

Public Class Methods

new(url) click to toggle source
# File lib/heroku_auto_scale/redis_operations.rb, line 7
def initialize(url)
  @redis_connection = Redis.new(url: url)
end

Public Instance Methods

check_queue_for_jobs(queue_name) click to toggle source
# File lib/heroku_auto_scale/redis_operations.rb, line 11
def check_queue_for_jobs(queue_name)
  check_queue(queue_name)
  redis_connection.llen(queue_name)
end

Private Instance Methods

check_queue(queue_name) click to toggle source
# File lib/heroku_auto_scale/redis_operations.rb, line 17
def check_queue(queue_name)
  available_keys = redis_connection.keys
  unless available_keys.include?(queue_name)
    raise "There is no key #{queue_name}, \n
           available keys are:\n
           #{available_keys}"
  end
end