Class: RedisClient::Cluster::Node::LatencyReplica
- Inherits:
-
BaseTopology
- Object
- BaseTopology
- RedisClient::Cluster::Node::LatencyReplica
- Defined in:
- lib/redis_client/cluster/node/latency_replica.rb
Constant Summary collapse
- DUMMY_LATENCY_MSEC =
100 * 1000 * 1000
- MEASURE_ATTEMPT_COUNT =
10
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, #replica_clients
Instance Method Summary collapse
- #any_replica_node_key(seed: nil) ⇒ Object
-
#clients_for_scanning(seed: nil) ⇒ Object
rubocop:disable Lint/UnusedMethodArgument.
-
#find_node_key_of_replica(primary_node_key, seed: nil) ⇒ Object
rubocop:disable Lint/UnusedMethodArgument.
- #process_topology_update!(replications, options) ⇒ Object
Methods inherited from BaseTopology
#any_primary_node_key, #initialize
Constructor Details
This class inherits a constructor from RedisClient::Cluster::Node::BaseTopology
Instance Method Details
#any_replica_node_key(seed: nil) ⇒ Object
20 21 22 23 |
# File 'lib/redis_client/cluster/node/latency_replica.rb', line 20 def any_replica_node_key(seed: nil) random = seed.nil? ? Random : Random.new(seed) @existed_replicas.sample(random: random)&.first || any_primary_node_key(seed: seed) end |
#clients_for_scanning(seed: nil) ⇒ Object
rubocop:disable Lint/UnusedMethodArgument
12 13 14 |
# File 'lib/redis_client/cluster/node/latency_replica.rb', line 12 def clients_for_scanning(seed: nil) # rubocop:disable Lint/UnusedMethodArgument @clients_for_scanning end |
#find_node_key_of_replica(primary_node_key, seed: nil) ⇒ Object
rubocop:disable Lint/UnusedMethodArgument
16 17 18 |
# File 'lib/redis_client/cluster/node/latency_replica.rb', line 16 def find_node_key_of_replica(primary_node_key, seed: nil) # rubocop:disable Lint/UnusedMethodArgument @replications.fetch(primary_node_key, EMPTY_ARRAY).first || primary_node_key end |
#process_topology_update!(replications, options) ⇒ Object
25 26 27 28 29 30 31 32 33 34 |
# File 'lib/redis_client/cluster/node/latency_replica.rb', line 25 def process_topology_update!(replications, ) super all_replica_clients = @clients.select { |k, _| @replica_node_keys.include?(k) } latencies = measure_latencies(all_replica_clients, @concurrent_worker) @replications.each_value { |keys| keys.sort_by! { |k| latencies.fetch(k) } } @replica_clients = select_replica_clients(@replications, @clients) @clients_for_scanning = select_clients_for_scanning(@replications, @clients) @existed_replicas = @replications.values.reject(&:empty?) end |