Contents

require 'redis'
require 'redis-namespace'
require 'connection_pool'

module Attention
  # A ConnectionPool of Redis connections used by {Publisher}s
  class RedisPool
    # @!visibility private
    attr_reader :pool

    # @return [RedisPool] A singleton instance of the ConnectionPool
    def self.instance
      @instance ||= new
      @pool ||= ->{ @instance.pool.with{ |redis| redis } }
    end

    private

    # As this is a singleton, +RedisPool.new+ is not public
    # @!visibility public
    # @api private
    def initialize
      pool_config = {
        size: Attention.options[:pool_size],
        timeout: Attention.options[:timeout]
      }

      @pool = ConnectionPool.new(pool_config){ Connection.new }
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
attention-0.0.6	lib/attention/redis_pool.rb
attention-0.0.5	lib/attention/redis_pool.rb
attention-0.0.4	lib/attention/redis_pool.rb
attention-0.0.3	lib/attention/redis_pool.rb
attention-0.0.2	lib/attention/redis_pool.rb