Module: Aerospike::Node::Verify::PeersGeneration

Defined in:
lib/aerospike/node/verify/peers_generation.rb

Class Method Summary collapse

Class Method Details

.call(node, info_map, peers) ⇒ Object

Raises:



25
26
27
28
29
30
31
32
33
34
35
36
 
# File 'lib/aerospike/node/verify/peers_generation.rb', line 25

def call(node, info_map, peers)
  gen_string = info_map.fetch('peers-generation', nil)

  raise Aerospike::Exceptions::Parse.new('peers-generation is empty', node) if gen_string.to_s.empty?

  generation = gen_string.to_i

  return if node.peers_generation.eql?(generation)

  Aerospike.logger.info("Node #{node.name} peers generation #{generation} changed")
  peers.generation_changed = true
end