Sha256: a445002a7e5b23e3f25d084013200f0616ea8bebc07e56901eb9d8aa51259353
Contents?: true
Size: 1.49 KB
Versions: 1
Compression:
Stored size: 1.49 KB
Contents
module RedisCluster class Pool attr_reader :nodes def initialize @nodes = [] end # TODO: type check def add_node!(node_options, slots) new_node = Node.new(node_options) node = @nodes.find {|n| n.name == new_node.name } || new_node node.slots = slots @nodes.push(node).uniq! end def delete_except!(master_hosts) names = master_hosts.map {|host, port| "#{host}:#{port}" } @nodes.delete_if {|n| !names.include?(n.name) } end # other_options: # asking # random_node def execute(method, args, other_options) return keys(args.first) if Configuration::SUPPORT_MULTI_NODE_METHODS.include?(method.to_s) key = key_by_command(method, args) raise NotSupportError if key.nil? node = other_options[:random_node] ? random_node : node_by(key) node.asking if other_options[:asking] node.execute(method, args) end def keys(glob = "*") on_each_node(:keys, glob).flatten end private def node_by(key) slot = Slot.slot_by(key) @nodes.find {|node| node.has_slot?(slot) } end def random_node @nodes.sample end def key_by_command(method, args) case method.to_s.downcase when 'info', 'multi', 'exec', 'slaveof', 'config', 'shutdown' nil else return args.first end end def on_each_node(method, *args) @nodes.map do |node| node.execute(method, args) end end end # end pool end
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
redis_cluster-0.2.3 | lib/redis_cluster/pool.rb |