Contents

module RedisCluster

  class Node
    # slots is a range array: [1..100, 300..500]
    attr_accessor :slots

    #
    # basic requires:
    #   {host: xxx.xxx.xx.xx, port: xxx}
    # redis cluster don't support select db, use default 0
    #
    def initialize(opts)
      @options = opts
      @slots = []
    end

    def name
      "#{@options[:host]}:#{@options[:port]}"
    end

    def host_hash
      {host: @options[:host], port: @options[:port]}
    end

    def has_slot?(slot)
      slots.any? {|range| range.include? slot }
    end

    def asking
      execute(:asking)
    end

    def execute(method, args, &block)
      connection.public_send(method, *args, &block)
    end

    def connection
      @connection ||= self.class.redis(@options)
    end

    def self.redis(options)
      extra_options = {timeout: Configuration::DEFAULT_TIMEOUT, driver: 'hiredis'.freeze}
      ::Redis.new(options.merge(extra_options))
    end

  end # end Node

end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
redis_cluster-0.3.0	lib/redis_cluster/node.rb
redis_cluster-0.2.9	lib/redis_cluster/node.rb
redis_cluster-0.2.8	lib/redis_cluster/node.rb
redis_cluster-0.2.7	lib/redis_cluster/node.rb
redis_cluster-0.2.6	lib/redis_cluster/node.rb
redis_cluster-0.2.5	lib/redis_cluster/node.rb