Sha256: b340a4789bf3b1bc1080866bb04a8a7df65b5ea7c8fd6a4602cf7385b692597d
Contents?: true
Size: 1.65 KB
Versions: 52
Compression:
Stored size: 1.65 KB
Contents
module Elasticsearch
module Transport
module Transport
# Handles node discovery ("sniffing")
#
class Sniffer
PROTOCOL = 'http'
attr_reader :transport
attr_accessor :timeout
# @param transport [Object] A transport instance
#
def initialize(transport)
@transport = transport
@timeout = transport.options[:sniffer_timeout] || 1
end
# Retrieves the node list from the Elasticsearch's
# [_Nodes Info API_](http://www.elasticsearch.org/guide/reference/api/admin-cluster-nodes-info/)
# and returns a normalized Array of information suitable for passing to transport.
#
# Shuffles the collection before returning it when the `randomize_hosts` option is set for transport.
#
# @return [Array<Hash>]
# @raise [SnifferTimeoutError]
#
def hosts
Timeout::timeout(timeout, SnifferTimeoutError) do
nodes = transport.perform_request('GET', '_nodes/http').body
hosts = nodes['nodes'].map do |id,info|
if info[PROTOCOL]
host, port = info[PROTOCOL]['publish_address'].split(':')
{ :id => id,
:name => info['name'],
:version => info['version'],
:host => host,
:port => port,
:roles => info['roles'],
:attributes => info['attributes'] }
end
end.compact
hosts.shuffle! if transport.options[:randomize_hosts]
hosts
end
end
end
end
end
end
Version data entries
52 entries across 52 versions & 6 rubygems