Class: Aerospike::Node

Inherits:
Object
  • Object
show all
Defined in:
lib/aerospike/node.rb,
lib/aerospike/node/generation.rb,
lib/aerospike/node/verify/name.rb,
lib/aerospike/node/refresh/info.rb,
lib/aerospike/node/refresh/peers.rb,
lib/aerospike/node/refresh/reset.rb,
lib/aerospike/node/refresh/failed.rb,
lib/aerospike/node/refresh/friends.rb,
lib/aerospike/node/refresh/partitions.rb,
lib/aerospike/node/verify/cluster_name.rb,
lib/aerospike/node/verify/peers_generation.rb,
lib/aerospike/node/verify/partition_generation.rb

Defined Under Namespace

Modules: Refresh, Verify Classes: Generation

Constant Summary collapse

PARTITIONS = 
4096
FULL_HEALTH = 
100

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(cluster, nv) ⇒ Node

Initialize server node with connection parameters.



31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
 
# File 'lib/aerospike/node.rb', line 31

def initialize(cluster, nv)
  @cluster = cluster
  @name = nv.name
  @aliases = Atomic.new(nv.aliases)
  @host = nv.host
  @use_new_info = Atomic.new(nv.use_new_info)
  @features = nv.features
  @cluster_name = nv.cluster_name

  # TODO: Re-use connection from node validator
  @tend_connection = nil

  # Assign host to first IP alias because the server identifies nodes
  # by IP address (not hostname).
  @host = nv.aliases[0]
  @health = Atomic.new(FULL_HEALTH)
  @peers_count = Atomic.new(0)
  @peers_generation = ::Aerospike::Node::Generation.new
  @partition_generation = ::Aerospike::Node::Generation.new
  @reference_count = Atomic.new(0)
  @responded = Atomic.new(false)
  @active = Atomic.new(true)
  @failures = Atomic.new(0)

  @connections = ::Aerospike::ConnectionPool.new(cluster, host)
end

Instance Attribute Details

#cluster ⇒ Object (readonly)

Returns the value of attribute cluster.



25
26
27
 
# File 'lib/aerospike/node.rb', line 25

def cluster
  @cluster
end

#cluster_name ⇒ Object (readonly)

Returns the value of attribute cluster_name.



25
26
27
 
# File 'lib/aerospike/node.rb', line 25

def cluster_name
  @cluster_name
end

#failures ⇒ Object (readonly)

Returns the value of attribute failures.



25
26
27
 
# File 'lib/aerospike/node.rb', line 25

def failures
  @failures
end

#features ⇒ Object (readonly)

Returns the value of attribute features.



25
26
27
 
# File 'lib/aerospike/node.rb', line 25

def features
  @features
end

#host ⇒ Object (readonly)

Returns the value of attribute host.



25
26
27
 
# File 'lib/aerospike/node.rb', line 25

def host
  @host
end

#name ⇒ Object (readonly)

Returns the value of attribute name.



25
26
27
 
# File 'lib/aerospike/node.rb', line 25

def name
  @name
end

#partition_generation ⇒ Object (readonly)

Returns the value of attribute partition_generation.



25
26
27
 
# File 'lib/aerospike/node.rb', line 25

def partition_generation
  @partition_generation
end

#peers_count ⇒ Object (readonly)

Returns the value of attribute peers_count.



25
26
27
 
# File 'lib/aerospike/node.rb', line 25

def peers_count
  @peers_count
end

#peers_generation ⇒ Object (readonly)

Returns the value of attribute peers_generation.



25
26
27
 
# File 'lib/aerospike/node.rb', line 25

def peers_generation
  @peers_generation
end

#reference_count ⇒ Object (readonly)

Returns the value of attribute reference_count.



25
26
27
 
# File 'lib/aerospike/node.rb', line 25

def reference_count
  @reference_count
end

#responded ⇒ Object (readonly)

Returns the value of attribute responded.



25
26
27
 
# File 'lib/aerospike/node.rb', line 25

def responded
  @responded
end

Instance Method Details

#==(other) ⇒ Object Also known as: eql? 



176
177
178
 
# File 'lib/aerospike/node.rb', line 176

def ==(other)
  other && other.is_a?(Node) && (@name == other.name)
end

#active! ⇒ Object

Sets node as active



108
109
110
 
# File 'lib/aerospike/node.rb', line 108

def active!
  @active.update { |_| true }
end

#active? ⇒ Boolean

Checks if the node is active

Returns:

  • (Boolean) 


118
119
120
 
# File 'lib/aerospike/node.rb', line 118

def active?
  @active.value
end

#aliases ⇒ Object 



162
163
164
 
# File 'lib/aerospike/node.rb', line 162

def aliases
  @aliases.value
end

#close ⇒ Object

Marks node as inactice and closes all cached connections



167
168
169
170
 
# File 'lib/aerospike/node.rb', line 167

def close
  inactive!
  close_connections
end

#decrease_health ⇒ Object

Decrease node Health as a result of bad connection or communication



93
94
95
 
# File 'lib/aerospike/node.rb', line 93

def decrease_health
  @health.update { |v| v - 1 }
end

#failed! ⇒ Object 



154
155
156
 
# File 'lib/aerospike/node.rb', line 154

def failed!
  @failures.update { |v| v + 1 }
end

#failed?(threshold = 1) ⇒ Boolean

Returns:

  • (Boolean) 


150
151
152
 
# File 'lib/aerospike/node.rb', line 150

def failed?(threshold = 1)
  @failures.value >= threshold
end

#get_connection(timeout) ⇒ Object

Get a connection to the node. If no cached connection is not available, a new connection will be created



60
61
62
63
64
65
66
67
68
 
# File 'lib/aerospike/node.rb', line 60

def get_connection(timeout)
  loop do
    conn = @connections.poll
    if conn.connected?
      conn.timeout = timeout.to_f
      return conn
    end
  end
end

#get_host ⇒ Object

Retrieves host for the node



103
104
105
 
# File 'lib/aerospike/node.rb', line 103

def get_host
  @host
end

#has_peers? ⇒ Boolean

Returns:

  • (Boolean) 


146
147
148
 
# File 'lib/aerospike/node.rb', line 146

def has_peers?
  @peers_count.value > 0
end

#hash ⇒ Object 



185
186
187
 
# File 'lib/aerospike/node.rb', line 185

def hash
  @name.hash
end

#inactive! ⇒ Object

Sets node as inactive



113
114
115
 
# File 'lib/aerospike/node.rb', line 113

def inactive!
  @active.update { |_| false }
end

#increase_reference_count! ⇒ Object 



122
123
124
 
# File 'lib/aerospike/node.rb', line 122

def increase_reference_count!
  @reference_count.update { |v| v + 1 }
end

#inspect ⇒ Object 



189
190
191
 
# File 'lib/aerospike/node.rb', line 189

def inspect
  "#<Aerospike::Node: @name=#{@name}, @host=#{@host}>"
end

#put_connection(conn) ⇒ Object

Put back a connection to the cache. If cache is full, the connection will be closed and discarded



72
73
74
75
 
# File 'lib/aerospike/node.rb', line 72

def put_connection(conn)
  conn.close if !active?
  @connections.offer(conn)
end

#referenced? ⇒ Boolean

Returns:

  • (Boolean) 


130
131
132
 
# File 'lib/aerospike/node.rb', line 130

def referenced?
  @reference_count.value > 0
end

#refresh_info(peers) ⇒ Object

Convenience wrappers for applying refresh operations to a node



197
198
199
 
# File 'lib/aerospike/node.rb', line 197

def refresh_info(peers)
  Node::Refresh::Info.(self, peers)
end

#refresh_partitions(peers) ⇒ Object 



201
202
203
 
# File 'lib/aerospike/node.rb', line 201

def refresh_partitions(peers)
  Node::Refresh::Partitions.(self, peers)
end

#refresh_peers(peers) ⇒ Object 



205
206
207
 
# File 'lib/aerospike/node.rb', line 205

def refresh_peers(peers)
  Node::Refresh::Peers.(self, peers)
end

#refresh_reset ⇒ Object 



209
210
211
 
# File 'lib/aerospike/node.rb', line 209

def refresh_reset
  Node::Refresh::Reset.(self)
end

#reset_failures! ⇒ Object 



158
159
160
 
# File 'lib/aerospike/node.rb', line 158

def reset_failures!
  @failures.value = 0
end

#reset_reference_count! ⇒ Object 



126
127
128
 
# File 'lib/aerospike/node.rb', line 126

def reset_reference_count!
  @reference_count.value = 0
end

#reset_responded! ⇒ Object 



142
143
144
 
# File 'lib/aerospike/node.rb', line 142

def reset_responded!
  @responded.value = false
end

#responded! ⇒ Object 



134
135
136
 
# File 'lib/aerospike/node.rb', line 134

def responded!
  @responded.value = true
end

#responded? ⇒ Boolean

Returns:

  • (Boolean) 


138
139
140
 
# File 'lib/aerospike/node.rb', line 138

def responded?
  @responded.value == true
end

#restore_health ⇒ Object

Mark the node as healthy



86
87
88
89
90
 
# File 'lib/aerospike/node.rb', line 86

def restore_health
  # There can be cases where health is full, but active is false.
  # Once a node has been marked inactive, it stays inactive.
  @health.value = FULL_HEALTH
end

#supports_feature?(feature) ⇒ Boolean

Returns:

  • (Boolean) 


172
173
174
 
# File 'lib/aerospike/node.rb', line 172

def supports_feature?(feature)
  @features.include?(feature.to_s)
end

#tend_connection ⇒ Object

Separate connection for refreshing



78
79
80
81
82
83
 
# File 'lib/aerospike/node.rb', line 78

def tend_connection
  if @tend_connection.nil? || @tend_connection.closed?
    @tend_connection = Cluster::CreateConnection.(cluster, host)
  end
  @tend_connection
end

#unhealthy? ⇒ Boolean

Check if the node is unhealthy

Returns:

  • (Boolean) 


98
99
100
 
# File 'lib/aerospike/node.rb', line 98

def unhealthy?
  @health.value <= 0
end

#use_new_info? ⇒ Boolean

Returns:

  • (Boolean) 


181
182
183
 
# File 'lib/aerospike/node.rb', line 181

def use_new_info?
  @use_new_info.value
end