class SidekiqMultiRedisClient::Config

Public Class Methods

clear_redi_params() click to toggle source
# File lib/sidekiq-multi-redis-client/config.rb, line 37
def self.clear_redi_params
  @current_redis = @redi = nil
end
current_redis() click to toggle source
# File lib/sidekiq-multi-redis-client/config.rb, line 22
def self.current_redis
  @current_redis
end
current_redis=(redis_connection_pool) click to toggle source
# File lib/sidekiq-multi-redis-client/config.rb, line 26
def self.current_redis=(redis_connection_pool)
  @current_redis = redis_connection_pool
end
error_count() click to toggle source
# File lib/sidekiq-multi-redis-client/config.rb, line 41
def self.error_count
  @error_count
end
inc_error_count() click to toggle source
# File lib/sidekiq-multi-redis-client/config.rb, line 45
def self.inc_error_count
  @error_count = @error_count + 1
end
multi_redis_job() click to toggle source
# File lib/sidekiq-multi-redis-client/config.rb, line 7
def self.multi_redis_job
  @multi_redis_job
end
multi_redis_job=(multi_redis_job) click to toggle source
# File lib/sidekiq-multi-redis-client/config.rb, line 3
def self.multi_redis_job=(multi_redis_job)
  @multi_redis_job = multi_redis_job
end
next_redis_connection() click to toggle source
# File lib/sidekiq-multi-redis-client/config.rb, line 30
def self.next_redis_connection
  if @redi.size == 1
    return @redi.first
  end
  @current_redis = @redi.reject {|redis_conn| @current_redis == redis_conn}.first
end
redi() click to toggle source
# File lib/sidekiq-multi-redis-client/config.rb, line 18
def self.redi
  @redi
end
redi=(array_of_redis_connection_pools) click to toggle source

Redises? An Array of redis ConnectionPools

# File lib/sidekiq-multi-redis-client/config.rb, line 13
def self.redi=(array_of_redis_connection_pools)
  @current_redis = array_of_redis_connection_pools.nil? ? nil : array_of_redis_connection_pools[0]
  @redi = array_of_redis_connection_pools
end
reset_error_count() click to toggle source
# File lib/sidekiq-multi-redis-client/config.rb, line 49
def self.reset_error_count
  @error_count = 0
end