Class: Autoscaler::CounterCacheRedis

Inherits:
Object
  • Object
show all
Defined in:
lib/autoscaler/counter_cache_redis.rb

Overview

Implements a cache for the number of heroku works currently up This permits some web/worker communication, which makes longer timeouts practical.

Defined Under Namespace

Classes: Expired

Instance Method Summary collapse

Constructor Details

#initialize(redis, timeout = 5 * 60, worker_type = 'worker') ⇒ CounterCacheRedis

Returns a new instance of CounterCacheRedis.

Parameters:

  • redis (Proc, ConnectionPool, Redis client) —

    redis interface Proc: e.g. Sidekiq.method(:redis) ConnectionPool: e.g. what you pass to Sidekiq.redis= Redis client: e.g. Redis.connect

  • timeout (Numeric) (defaults to: 5 * 60) —

    number of seconds to allow before expiration

  • worker_type (String) (defaults to: 'worker') —

    the name of the worker type, for cache keys



11
12
13
14
15
 
# File 'lib/autoscaler/counter_cache_redis.rb', line 11

def initialize(redis, timeout = 5 * 60, worker_type = 'worker')
  @redis = redis
  @timeout = timeout
  @worker_type = worker_type
end

Instance Method Details

#counter ⇒ Object

Current value. Uses the Hash#fetch api - pass a block to use in place of expired values or it will raise an exception.

Raises:



26
27
28
29
30
31
 
# File 'lib/autoscaler/counter_cache_redis.rb', line 26

def counter
  value = redis {|c| c.get(key)}
  return value.to_i if value
  return yield if block_given?
  raise Expired
end

#counter=(value) ⇒ Object

Parameters:

  • value (Numeric) —

    new counter value



18
19
20
 
# File 'lib/autoscaler/counter_cache_redis.rb', line 18

def counter=(value)
  redis {|c| c.setex(key, @timeout, value)}
end