Contents

require "redis"

module Kredis::Connections
  mattr_accessor :connections, default: Hash.new
  mattr_accessor :configurator

  def configured_for(name)
    connections[name] ||= begin
      logger&.info "[Kredis] Connected to #{name}"
      Redis.new configurator.config_for("redis/#{name}")
    end
  end

  def clear_all
    logger&.info "[Kredis] Connections all cleared"
    connections.each_value(&:flushdb)
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
kredis-0.2.2	lib/kredis/connections.rb
kredis-0.2.1	lib/kredis/connections.rb
kredis-0.2.0	lib/kredis/connections.rb