module QPush::Base::RedisHelper::ClassMethods

Public Instance Methods

build_keys(namespace, priorities) click to toggle source
# File lib/qpush/base/redis.rb, line 35
def build_keys(namespace, priorities)
  name = "#{QPush::Base::KEY}:#{namespace}"
  keys = Hash[QPush::Base::SUB_KEYS.collect { |key| [key, "#{name}:#{key}"] }]
  keys[:perform_list] = (1..priorities).collect { |num| "#{keys[:perform]}:#{num}" }
  keys
end
build_pool(pool, url) click to toggle source
# File lib/qpush/base/redis.rb, line 29
def build_pool(pool, url)
  ConnectionPool.new(size: pool) do
    Redis.new(url: url)
  end
end
redis() { |conn| ... } click to toggle source
# File lib/qpush/base/redis.rb, line 19
def redis
  redis_pool.with do |conn|
    yield conn
  end
end
redis_pool() click to toggle source
# File lib/qpush/base/redis.rb, line 25
def redis_pool
  @redis_pool ||= build_pool(config.redis_pool, config.redis_url)
end