mirror of
https://github.com/mperham/sidekiq.git
synced 2022-11-09 13:52:34 -05:00
Added option to specify the redis driver (hiredis, ..)
This commit is contained in:
parent
1c3a919790
commit
614dbfef77
2 changed files with 5 additions and 3 deletions
|
@ -5,6 +5,7 @@ HEAD
|
|||
This gives us a full Thread stack and also lowers Sidekiq's memory
|
||||
usage.
|
||||
- Add pagination for lists within the Web UI [#253]
|
||||
- Add possibility to specify which Redis driver to use: *hiredis*, *synchrony* or *ruby* (default)
|
||||
|
||||
2.0.3
|
||||
-----------
|
||||
|
|
|
@ -6,16 +6,17 @@ module Sidekiq
|
|||
class RedisConnection
|
||||
def self.create(options={})
|
||||
url = options[:url] || ENV['REDISTOGO_URL'] || '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)
|
||||
|
||||
ConnectionPool.new(:timeout => 1, :size => size) do
|
||||
build_client(url, options[:namespace])
|
||||
build_client(url, options[:namespace], driver)
|
||||
end
|
||||
end
|
||||
|
||||
def self.build_client(url, namespace)
|
||||
client = Redis.connect(:url => url)
|
||||
def self.build_client(url, namespace, driver)
|
||||
client = Redis.connect(:url => url, :driver => driver)
|
||||
if namespace
|
||||
Redis::Namespace.new(namespace, :redis => client)
|
||||
else
|
||||
|
|
Loading…
Add table
Reference in a new issue