Contents

require 'monitor'

module Redistat
  module Connection
    
    REQUIRED_SERVER_VERSION = "1.3.10"
    
    # TODO: Create a ConnectionPool instance object using Sychronize mixin to replace Connection class
    
    class << self
      
      # TODO: clean/remove all ref-less connections
      
      def get(ref = nil)
        ref ||= :default
        synchronize do
          connections[references[ref]] || create
        end
      end
      
      def add(conn, ref = nil)
        ref ||= :default
        synchronize do
          check_redis_version(conn)
          references[ref] = conn.client.id
          connections[conn.client.id] = conn
        end
      end
      
      def create(options = {})
        synchronize do
          options = options.clone
          ref = options.delete(:ref) || :default
          options.reverse_merge!(default_options)
          conn = (connections[connection_id(options)] ||= connection(options))
          references[ref] = conn.client.id
          conn
        end
      end
      
      def connections
        @connections ||= {}
      end
      
      def references
        @references ||= {}
      end
      
      private
      
      def monitor
        @monitor ||= Monitor.new
      end
      
      def synchronize(&block)
        monitor.synchronize(&block)
      end
      
      def connection(options)
        check_redis_version(Redis.new(options))
      end
      
      def connection_id(options = {})
        options = options.reverse_merge(default_options)
        "redis://#{options[:host]}:#{options[:port]}/#{options[:db]}"
      end
      
      def check_redis_version(conn)
        raise RedisServerIsTooOld if conn.info["redis_version"] < REQUIRED_SERVER_VERSION
        conn
      end
      
      def default_options
        {
          :host => '127.0.0.1',
          :port => 6379,
          :db => 0,
          :timeout => 5
        }
      end
      
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
redistat-0.3.0	lib/redistat/connection.rb