Contents

require "redis"

module Kredis::Connections
  mattr_accessor :connections, default: Hash.new
  mattr_accessor :configurator
  mattr_accessor :connector, default: ->(config) { Redis.new(config) }

  def configured_for(name)
    connections[name] ||= begin
      Kredis.instrument :meta, message: "Connected to #{name}" do
        connector.call configurator.config_for("redis/#{name}")
      end
    end
  end

  def clear_all
    Kredis.instrument :meta, message: "Connections all cleared" do
      connections.each_value do |connection|
        if Kredis.namespace
          keys = connection.keys("#{Kredis.namespace}:*")
          connection.del keys if keys.any?
        else
          connection.flushdb
        end
      end
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
kredis-1.5.0	lib/kredis/connections.rb
kredis-1.4.0	lib/kredis/connections.rb
kredis-1.3.0.1	lib/kredis/connections.rb
kredis-1.3.0	lib/kredis/connections.rb
kredis-1.2.0	lib/kredis/connections.rb
kredis-1.1.0	lib/kredis/connections.rb
kredis-1.0.1	lib/kredis/connections.rb
kredis-1.0.0	lib/kredis/connections.rb