Contents

require 'rediska/databases/memory'
require 'rediska/databases/pstore'
require 'rediska/sorted_set_argument_handler'
require 'rediska/sorted_set_store'
require 'rediska/zset'
require 'rediska/driver'

module Rediska
  class Connection
    include Driver

    class << self
      def databases
        @databases ||= Hash.new {|h,k| h[k] = [] }
      end

      def reset
        if @databases
          @databases.values do |db|
            db.class.reset
            db.each(&:clear)
          end

          @databases = nil
        end
      end

      def connect(options = {})
        new(options)
      end
    end

    def initialize(options = {})
      @options = options
      @database_id = 0
    end

    def database_instance_key
      @database_instance_key ||= [@options[:host], @options[:port], Rediska.configuration.namespace].
        compact.join(':')
    end

    def databases
      self.class.databases[database_instance_key]
    end

    def find_database(id = database_id)
      databases[id] ||= db_class.new(database_instance_key, id)
    end

    def data
      find_database
    end

    private
    def db_class
      case Rediska.configuration.database
      when :memory
        Rediska::Databases::Memory
      when :filesystem
        Rediska::Databases::PStore
      else
        raise ArgumentError, "invalid database type: #{Rediska.configuration.database}"
      end
    end
   end
end

Version data entries

10 entries across 10 versions & 1 rubygems

Version	Path
rediska-0.0.11	lib/rediska/connection.rb
rediska-0.0.10	lib/rediska/connection.rb
rediska-0.0.9	lib/rediska/connection.rb
rediska-0.0.8	lib/rediska/connection.rb
rediska-0.0.7	lib/rediska/connection.rb
rediska-0.0.6	lib/rediska/connection.rb
rediska-0.0.5	lib/rediska/connection.rb
rediska-0.0.4	lib/rediska/connection.rb
rediska-0.0.3	lib/rediska/connection.rb
rediska-0.0.2	lib/rediska/connection.rb