org.elasticsearch.cluster.node

Class DiscoveryNodes

java.lang.Object

org.elasticsearch.cluster.AbstractDiffable<DiscoveryNodes>

org.elasticsearch.cluster.node.DiscoveryNodes

All Implemented Interfaces:

java.lang.Iterable<DiscoveryNode>, Diffable<DiscoveryNodes>, Writeable

public class DiscoveryNodes
extends AbstractDiffable<DiscoveryNodes>
implements java.lang.Iterable<DiscoveryNode>

This class holds all DiscoveryNode in the cluster and provides convenience methods to access, modify merge / diff discovery nodes.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DiscoveryNodes.Builder
static class	DiscoveryNodes.Delta

Nested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable

Writeable.Reader<V>, Writeable.Writer<V>

Field Summary

Fields

Modifier and Type	Field and Description
static DiscoveryNodes	EMPTY_NODES

Method Summary

Modifier and Type	Method and Description
static DiscoveryNodes.Builder	builder()
static DiscoveryNodes.Builder	builder(DiscoveryNodes nodes)
DiscoveryNodes.Delta	delta(DiscoveryNodes other) Returns the changes comparing this nodes to the provided nodes.
DiscoveryNode	findByAddress(TransportAddress address) Get a node by its address
DiscoveryNode	get(java.lang.String nodeId) Get a node by its id
ImmutableOpenMap<java.lang.String,DiscoveryNode>	getDataNodes() Get a Map of the discovered data nodes arranged by their ids
ImmutableOpenMap<java.lang.String,DiscoveryNode>	getIngestNodes()
Version	getLargestNonClientNodeVersion() Returns the version of the node with the youngest version in the cluster that is not a client node.
DiscoveryNode	getLocalNode() Get the local node
java.lang.String	getLocalNodeId() Get the id of the local node
ImmutableOpenMap<java.lang.String,DiscoveryNode>	getMasterAndDataNodes() Get a Map of the discovered master and data nodes arranged by their ids
DiscoveryNode	getMasterNode() Get the master node
java.lang.String	getMasterNodeId() Get the id of the master node
ImmutableOpenMap<java.lang.String,DiscoveryNode>	getMasterNodes() Get a Map of the discovered master nodes arranged by their ids
Version	getMaxNodeVersion() Returns the version of the node with the yougest version in the cluster
Version	getMinNodeVersion() Returns the version of the node with the oldest version in the cluster.
ImmutableOpenMap<java.lang.String,DiscoveryNode>	getNodes() Get a Map of the discovered nodes arranged by their ids
int	getSize() Get the number of known nodes
Version	getSmallestNonClientNodeVersion() Returns the version of the node with the oldest version in the cluster that is not a client node If there are no non-client nodes, Version.CURRENT will be returned.
boolean	isAllNodes(java.lang.String... nodesIds)
boolean	isLocalNodeElectedMaster() Returns true if the local node is the elected master node.
java.util.Iterator<DiscoveryNode>	iterator()
DiscoveryNodes	newNode(DiscoveryNode node)
boolean	nodeExists(DiscoveryNode node) Determine if a given node exists
boolean	nodeExists(java.lang.String nodeId) Determine if a given node id exists
static Diff<DiscoveryNodes>	readDiffFrom(StreamInput in, DiscoveryNode localNode)
static DiscoveryNodes	readFrom(StreamInput in, DiscoveryNode localNode)
DiscoveryNodes	removeDeadMembers(java.util.Set<java.lang.String> newNodes, java.lang.String masterNodeId)
DiscoveryNode	resolveNode(java.lang.String node) Resolve a node with a given id
java.lang.String[]	resolveNodes(java.lang.String... nodes) resolves a set of node "descriptions" to concrete and existing node ids.
java.lang.String	toString()
void	writeTo(StreamOutput out) Write this into the StreamOutput.

Methods inherited from class org.elasticsearch.cluster.AbstractDiffable

diff, get, readDiffFrom

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

EMPTY_NODES

public static final DiscoveryNodes EMPTY_NODES

Method Detail

iterator

public java.util.Iterator<DiscoveryNode> iterator()

Specified by:

iterator in interface java.lang.Iterable<DiscoveryNode>

isLocalNodeElectedMaster

public boolean isLocalNodeElectedMaster()

Returns true if the local node is the elected master node.

getSize

public int getSize()

Get the number of known nodes

Returns:

number of nodes

getNodes

public ImmutableOpenMap<java.lang.String,DiscoveryNode> getNodes()

Get a Map of the discovered nodes arranged by their ids

Returns:

Map of the discovered nodes arranged by their ids

getDataNodes

public ImmutableOpenMap<java.lang.String,DiscoveryNode> getDataNodes()

Get a Map of the discovered data nodes arranged by their ids

Returns:

Map of the discovered data nodes arranged by their ids

getMasterNodes

public ImmutableOpenMap<java.lang.String,DiscoveryNode> getMasterNodes()

Get a Map of the discovered master nodes arranged by their ids

Returns:

Map of the discovered master nodes arranged by their ids

getIngestNodes

public ImmutableOpenMap<java.lang.String,DiscoveryNode> getIngestNodes()

Returns:

All the ingest nodes arranged by their ids

getMasterAndDataNodes

public ImmutableOpenMap<java.lang.String,DiscoveryNode> getMasterAndDataNodes()

Get a Map of the discovered master and data nodes arranged by their ids

Returns:

Map of the discovered master and data nodes arranged by their ids

get

public DiscoveryNode get(java.lang.String nodeId)

Get a node by its id

Parameters:

nodeId - id of the wanted node

Returns:

wanted node if it exists. Otherwise null

nodeExists

public boolean nodeExists(java.lang.String nodeId)

Determine if a given node id exists

Parameters:

nodeId - id of the node which existence should be verified

Returns:

true if the node exists. Otherwise false

nodeExists

public boolean nodeExists(DiscoveryNode node)

Determine if a given node exists

Parameters:

node - of the node which existence should be verified

Returns:

true if the node exists. Otherwise false

getMasterNodeId

public java.lang.String getMasterNodeId()

Get the id of the master node

Returns:

id of the master

getLocalNodeId

public java.lang.String getLocalNodeId()

Get the id of the local node

Returns:

id of the local node

getLocalNode

public DiscoveryNode getLocalNode()

Get the local node

Returns:

local node

getMasterNode

public DiscoveryNode getMasterNode()

Get the master node

Returns:

master node

findByAddress

public DiscoveryNode findByAddress(TransportAddress address)

Get a node by its address

Parameters:

address - TransportAddress of the wanted node

Returns:

node identified by the given address or null if no such node exists

isAllNodes

public boolean isAllNodes(java.lang.String... nodesIds)

getSmallestNonClientNodeVersion

public Version getSmallestNonClientNodeVersion()

Returns the version of the node with the oldest version in the cluster that is not a client node If there are no non-client nodes, Version.CURRENT will be returned.

Returns:

the oldest version in the cluster

getLargestNonClientNodeVersion

public Version getLargestNonClientNodeVersion()

Returns the version of the node with the youngest version in the cluster that is not a client node. If there are no non-client nodes, Version.CURRENT will be returned.

Returns:

the youngest version in the cluster

getMinNodeVersion

public Version getMinNodeVersion()

Returns the version of the node with the oldest version in the cluster.

Returns:

the oldest version in the cluster

getMaxNodeVersion

public Version getMaxNodeVersion()

Returns the version of the node with the yougest version in the cluster

Returns:

the youngest version in the cluster

resolveNode

public DiscoveryNode resolveNode(java.lang.String node)

Resolve a node with a given id

Parameters:

node - id of the node to discover

Returns:

discovered node matching the given id

Throws:

java.lang.IllegalArgumentException - if more than one node matches the request or no nodes have been resolved

resolveNodes

public java.lang.String[] resolveNodes(java.lang.String... nodes)

resolves a set of node "descriptions" to concrete and existing node ids. "descriptions" can be (resolved in this order): - "_local" or "_master" for the relevant nodes - a node id - a wild card pattern that will be matched against node names - a "attr:value" pattern, where attr can be a node role (master, data, ingest etc.) in which case the value can be true of false or a generic node attribute name in which case value will be treated as a wildcard and matched against the node attribute values.

removeDeadMembers

public DiscoveryNodes removeDeadMembers(java.util.Set<java.lang.String> newNodes,
                                        java.lang.String masterNodeId)

newNode

public DiscoveryNodes newNode(DiscoveryNode node)

delta

public DiscoveryNodes.Delta delta(DiscoveryNodes other)

Returns the changes comparing this nodes to the provided nodes.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

writeTo

public void writeTo(StreamOutput out)
             throws java.io.IOException

Description copied from interface: Writeable

Write this into the StreamOutput.

Specified by:

writeTo in interface Writeable

Throws:

java.io.IOException

readFrom

public static DiscoveryNodes readFrom(StreamInput in,
                                      DiscoveryNode localNode)
                               throws java.io.IOException

Throws:

java.io.IOException

readDiffFrom

public static Diff<DiscoveryNodes> readDiffFrom(StreamInput in,
                                                DiscoveryNode localNode)
                                         throws java.io.IOException

Throws:

java.io.IOException

builder

public static DiscoveryNodes.Builder builder()

builder

public static DiscoveryNodes.Builder builder(DiscoveryNodes nodes)