Class: RedisClient::Cluster::Node::RandomReplica

Inherits:
BaseTopology
  • Object
show all
Defined in:
lib/redis_client/cluster/node/random_replica.rb

Instance Attribute Summary

Attributes inherited from BaseTopology

#clients, #primary_clients

Instance Method Summary collapse

Methods inherited from BaseTopology

#any_primary_node_key, #initialize, #process_topology_update!

Constructor Details

This class inherits a constructor from RedisClient::Cluster::Node::BaseTopology

Instance Method Details

#any_replica_node_key(seed: nil) ⇒ Object 



29
30
31
 
# File 'lib/redis_client/cluster/node/random_replica.rb', line 29

def any_replica_node_key(seed: nil)
  @replica_node_keys.sample(random: make_random(seed)) || any_primary_node_key(seed: seed)
end

#clients_for_scanning(seed: nil) ⇒ Object 



14
15
16
17
18
19
20
21
 
# File 'lib/redis_client/cluster/node/random_replica.rb', line 14

def clients_for_scanning(seed: nil)
  random = make_random(seed)
  keys = @replications.map do |primary_node_key, replica_node_keys|
    replica_node_keys.empty? ? primary_node_key : replica_node_keys.sample(random: random)
  end

  clients.select { |k, _| keys.include?(k) }
end

#find_node_key_of_replica(primary_node_key, seed: nil) ⇒ Object 



23
24
25
26
27
 
# File 'lib/redis_client/cluster/node/random_replica.rb', line 23

def find_node_key_of_replica(primary_node_key, seed: nil)
  replica_node_keys = @replications.fetch(primary_node_key, EMPTY_ARRAY)
  replica_node_key = replica_node_keys.size <= 1 ? replica_node_keys.first : replica_node_keys.sample(random: make_random(seed))
  replica_node_key || primary_node_key
end

#replica_clients ⇒ Object 



9
10
11
12
 
# File 'lib/redis_client/cluster/node/random_replica.rb', line 9

def replica_clients
  keys = @replications.values.filter_map(&:sample)
  @clients.select { |k, _| keys.include?(k) }
end