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