mirror of
https://github.com/mperham/sidekiq.git
synced 2022-11-09 13:52:34 -05:00
27 lines
743 B
Ruby
27 lines
743 B
Ruby
require 'connection_pool'
|
|
require 'redis/namespace'
|
|
|
|
module Sidekiq
|
|
class RedisConnection
|
|
def self.create(options={})
|
|
url = options[:url] || ENV['REDISTOGO_URL'] || 'redis://localhost:6379/0'
|
|
if options[:use_pool] != false
|
|
ConnectionPool.new(:timeout => 1, :size => (options[:size] || Sidekiq.options[:concurrency] | 25)) do
|
|
build_client(url, options[:namespace])
|
|
end
|
|
else
|
|
build_client(url, options[:namespace])
|
|
end
|
|
end
|
|
|
|
def self.build_client(url, namespace)
|
|
client = Redis.connect(:url => url)
|
|
if namespace
|
|
Redis::Namespace.new(namespace, :redis => client)
|
|
else
|
|
client
|
|
end
|
|
end
|
|
private_class_method :build_client
|
|
end
|
|
end
|