class Redis::Cluster::Option

Keep options for Redis Cluster Client

Constants

DEFAULT_SCHEME
SECURE_SCHEME
VALID_SCHEMES

Public Class Methods

new(options) click to toggle source
# File lib/redis/cluster/option.rb, line 14
def initialize(options)
  options = options.dup
  node_addrs = options.delete(:cluster)
  @node_uris = build_node_uris(node_addrs)
  @replica = options.delete(:replica) == true
  @options = options
end

Public Instance Methods

add_node(host, port) click to toggle source
# File lib/redis/cluster/option.rb, line 39
def add_node(host, port)
  @node_uris << parse_node_hash(host: host, port: port)
end
per_node_key() click to toggle source
# File lib/redis/cluster/option.rb, line 22
def per_node_key
  @node_uris.map { |uri| [NodeKey.build_from_uri(uri), @options.merge(url: uri.to_s)] }
            .to_h
end
secure?() click to toggle source
# File lib/redis/cluster/option.rb, line 27
def secure?
  @node_uris.any? { |uri| uri.scheme == SECURE_SCHEME } || @options[:ssl_params] || false
end
update_node(addrs) click to toggle source
# File lib/redis/cluster/option.rb, line 35
def update_node(addrs)
  @node_uris = build_node_uris(addrs)
end
use_replica?() click to toggle source
# File lib/redis/cluster/option.rb, line 31
def use_replica?
  @replica
end

Private Instance Methods

build_node_uris(addrs) click to toggle source
# File lib/redis/cluster/option.rb, line 45
def build_node_uris(addrs)
  raise InvalidClientOptionError, 'Redis option of `cluster` must be an Array' unless addrs.is_a?(Array)
  addrs.map { |addr| parse_node_addr(addr) }
end
parse_node_addr(addr) click to toggle source
# File lib/redis/cluster/option.rb, line 50
def parse_node_addr(addr)
  case addr
  when String
    parse_node_url(addr)
  when Hash
    parse_node_hash(addr)
  else
    raise InvalidClientOptionError, 'Redis option of `cluster` must includes String or Hash'
  end
end
parse_node_hash(addr) click to toggle source
# File lib/redis/cluster/option.rb, line 69
def parse_node_hash(addr)
  addr = addr.map { |k, v| [k.to_sym, v] }.to_h
  raise InvalidClientOptionError, 'Redis option of `cluster` must includes `:host` and `:port` keys' if addr.values_at(:host, :port).any?(&:nil?)
  URI::Generic.build(scheme: DEFAULT_SCHEME, host: addr[:host], port: addr[:port].to_i)
end
parse_node_url(addr) click to toggle source
# File lib/redis/cluster/option.rb, line 61
def parse_node_url(addr)
  uri = URI(addr)
  raise InvalidClientOptionError, "Invalid uri scheme #{addr}" unless VALID_SCHEMES.include?(uri.scheme)
  uri
rescue URI::InvalidURIError => err
  raise InvalidClientOptionError, err.message
end