https://github.com/mperham/sidekiq
Tip revision: 62adfd863975220b41125c6f74190eab81b868ae authored by Mike Perham on 04 March 2013, 00:24:36 UTC
Remove superfluous binary and remove examples from gem
Remove superfluous binary and remove examples from gem
Tip revision: 62adfd8
redis_connection.rb
require 'connection_pool'
require 'redis'
require 'redis/namespace'
module Sidekiq
class RedisConnection
def self.create(options={})
url = options[:url] || determine_redis_provider || 'redis://localhost:6379/0'
driver = options[:driver] || 'ruby'
# need a connection for Fetcher and Retry
size = options[:size] || (Sidekiq.server? ? (Sidekiq.options[:concurrency] + 2) : 5)
namespace = options[:namespace]
ConnectionPool.new(:timeout => 1, :size => size) do
build_client(url, namespace, driver)
end
end
def self.build_client(url, namespace, driver)
client = Redis.connect(:url => url, :driver => driver)
if namespace
Redis::Namespace.new(namespace, :redis => client)
else
client
end
end
private_class_method :build_client
# Not public
def self.determine_redis_provider
return ENV['REDISTOGO_URL'] if ENV['REDISTOGO_URL']
provider = ENV['REDIS_PROVIDER'] || 'REDIS_URL'
ENV[provider]
end
end
end