Class: RedisClient::Cluster::Node::RandomReplicaOrPrimary
- Inherits:
-
BaseTopology
- Object
- BaseTopology
- RedisClient::Cluster::Node::RandomReplicaOrPrimary
show all
- Defined in:
- lib/redis_client/cluster/node/random_replica_or_primary.rb
Constant Summary
Constants inherited
from BaseTopology
BaseTopology::EMPTY_ARRAY, BaseTopology::EMPTY_HASH, BaseTopology::IGNORE_GENERIC_CONFIG_KEYS
Instance Attribute Summary
Attributes inherited from BaseTopology
#clients, #primary_clients
Instance Method Summary
collapse
#any_primary_node_key, #initialize, #process_topology_update!
Instance Method Details
#any_replica_node_key(seed: nil) ⇒ Object
34
35
36
37
|
# File 'lib/redis_client/cluster/node/random_replica_or_primary.rb', line 34
def any_replica_node_key(seed: nil)
random = seed.nil? ? Random : Random.new(seed)
@replica_node_keys.sample(random: random) || 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_or_primary.rb', line 14
def clients_for_scanning(seed: nil)
random = seed.nil? ? Random : Random.new(seed)
keys = @replications.map do |primary_node_key, replica_node_keys|
decide_use_primary?(random, replica_node_keys.size) ? 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
28
29
30
31
32
|
# File 'lib/redis_client/cluster/node/random_replica_or_primary.rb', line 23
def find_node_key_of_replica(primary_node_key, seed: nil)
random = seed.nil? ? Random : Random.new(seed)
replica_node_keys = @replications.fetch(primary_node_key, EMPTY_ARRAY)
if decide_use_primary?(random, replica_node_keys.size)
primary_node_key
else
replica_node_keys.sample(random: random) || primary_node_key
end
end
|
#replica_clients ⇒ Object
9
10
11
12
|
# File 'lib/redis_client/cluster/node/random_replica_or_primary.rb', line 9
def replica_clients
keys = @replications.values.filter_map(&:sample)
@clients.select { |k, _| keys.include?(k) }
end
|