org.graylog2.indexer.cluster

Class Cluster

java.lang.Object

org.graylog2.indexer.cluster.Cluster

public class Cluster
extends Object

Constructor Summary

Constructors

Constructor and Description
Cluster(org.elasticsearch.node.Node node, Deflector deflector)

Method Summary

Modifier and Type	Method and Description
int	getActiveShards()
List<org.elasticsearch.action.admin.cluster.node.info.NodeInfo>	getAllNodes()
List<org.elasticsearch.action.admin.cluster.node.info.NodeInfo>	getDataNodes()
org.elasticsearch.action.admin.cluster.health.ClusterHealthStatus	getHealth()
int	getInitializingShards()
String	getName()
int	getNumberOfNodes()
int	getRelocatingShards()
int	getUnassignedShards()
boolean	isConnectedAndHealthy() Check if the Elasticsearch Node is connected and that the cluster health status is not ClusterHealthStatus.RED.
String	nodeIdToHostName(String nodeId)
String	nodeIdToName(String nodeId)

Methods inherited from class java.lang.Object

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

Constructor Detail

Cluster

@Inject
public Cluster(org.elasticsearch.node.Node node,
                       Deflector deflector)

Method Detail

getName

public String getName()

getHealth

public org.elasticsearch.action.admin.cluster.health.ClusterHealthStatus getHealth()

getActiveShards

public int getActiveShards()

getInitializingShards

public int getInitializingShards()

getUnassignedShards

public int getUnassignedShards()

getRelocatingShards

public int getRelocatingShards()

getNumberOfNodes

public int getNumberOfNodes()

getDataNodes

public List<org.elasticsearch.action.admin.cluster.node.info.NodeInfo> getDataNodes()

getAllNodes

public List<org.elasticsearch.action.admin.cluster.node.info.NodeInfo> getAllNodes()

nodeIdToName

public String nodeIdToName(String nodeId)

nodeIdToHostName

public String nodeIdToHostName(String nodeId)

isConnectedAndHealthy

public boolean isConnectedAndHealthy()

Check if the Elasticsearch Node is connected and that the cluster health status is not ClusterHealthStatus.RED.

Returns:

true if the Elasticsearch client is up and the cluster is healthy, false otherwise