Sha256: 09412905e86ede701d52ff9ca38eba0328a9a73e523f197dfc6c96c028d67834

Contents?: true

Size: 548 Bytes

Versions: 35

Compression:

Stored size: 548 Bytes

Contents

#!/usr/bin/env ruby

require 'eventmachine'
# the redis/synchrony gems need to be required in this particular order, see
# the redis-rb README for details
require 'hiredis'
require 'em-synchrony'
require 'redis/connection/synchrony'
require 'redis'

require 'em-synchrony/connection_pool'

module Flapjack
  class RedisPool < EventMachine::Synchrony::ConnectionPool

    def initialize(opts = {})
      config = opts.delete(:config)
      @size = opts[:size] || 5
      super(:size => @size) {
        ::Redis.new(config)
      }
    end

  end
end

Version data entries

35 entries across 35 versions & 1 rubygems

Version Path
flapjack-0.7.28 lib/flapjack/redis_pool.rb
flapjack-0.7.27 lib/flapjack/redis_pool.rb
flapjack-0.7.26 lib/flapjack/redis_pool.rb
flapjack-0.7.25 lib/flapjack/redis_pool.rb
flapjack-0.7.22 lib/flapjack/redis_pool.rb
flapjack-0.7.21 lib/flapjack/redis_pool.rb
flapjack-0.7.20 lib/flapjack/redis_pool.rb
flapjack-0.7.19 lib/flapjack/redis_pool.rb
flapjack-0.7.18 lib/flapjack/redis_pool.rb
flapjack-0.7.17 lib/flapjack/redis_pool.rb
flapjack-0.7.16 lib/flapjack/redis_pool.rb
flapjack-0.7.15 lib/flapjack/redis_pool.rb
flapjack-0.7.14 lib/flapjack/redis_pool.rb
flapjack-0.7.13 lib/flapjack/redis_pool.rb
flapjack-0.7.12 lib/flapjack/redis_pool.rb
flapjack-0.7.11 lib/flapjack/redis_pool.rb
flapjack-0.7.10 lib/flapjack/redis_pool.rb
flapjack-0.7.9 lib/flapjack/redis_pool.rb
flapjack-0.7.8 lib/flapjack/redis_pool.rb
flapjack-0.7.7 lib/flapjack/redis_pool.rb