org.graylog2.indexer.cluster

Class Cluster

java.lang.Object

org.graylog2.indexer.cluster.Cluster

@Singleton
public class Cluster
extends Object

Constructor Summary

Constructors

Constructor and Description
Cluster(org.elasticsearch.client.Client client, IndexSetRegistry indexSetRegistry, ScheduledExecutorService scheduler, com.github.joschi.jadconfig.util.Duration requestTimeout)

Method Summary

Modifier and Type	Method and Description
org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse	deflectorHealth() Requests the cluster health for the current write index.
Map<String,org.elasticsearch.action.admin.cluster.node.info.NodeInfo>	getAllNodes()
Map<String,org.elasticsearch.action.admin.cluster.node.info.NodeInfo>	getDataNodes()
Map<String,org.elasticsearch.action.admin.cluster.node.stats.NodeStats>	getNodesStats(String... nodesIds)
org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse	health() Requests the cluster health for all indices managed by Graylog.
boolean	isConnected() Check if the Elasticsearch Node is connected and that there are other nodes in the cluster.
boolean	isDeflectorHealthy() Check if the deflector (write index) health status is not ClusterHealthStatus.RED and that the deflector is up.
boolean	isHealthy() Check if the cluster health status is not ClusterHealthStatus.RED and that the deflector is up.
String	nodeIdToHostName(String nodeId)
String	nodeIdToName(String nodeId)
void	updateDataNodeList(Map<String,org.elasticsearch.cluster.node.DiscoveryNode> nodes)
void	waitForConnectedAndDeflectorHealthy() Blocks until the Elasticsearch cluster and current write index is healthy again or the default timeout fires.
void	waitForConnectedAndDeflectorHealthy(long timeout, TimeUnit unit) Blocks until the Elasticsearch cluster and current write index is healthy again or the given timeout fires.

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.client.Client client,
                       IndexSetRegistry indexSetRegistry,
                       @Named(value="daemonScheduler")
                       ScheduledExecutorService scheduler,
                       @Named(value="elasticsearch_request_timeout")
                       com.github.joschi.jadconfig.util.Duration requestTimeout)

Method Detail

health

public org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse health()

Requests the cluster health for all indices managed by Graylog. (default: graylog_*)

Returns:

the cluster health response

deflectorHealth

public org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse deflectorHealth()

Requests the cluster health for the current write index. (deflector) This can be used to decide if the current write index is healthy and writable even when older indices have problems.

Returns:

the cluster health response

getDataNodes

public Map<String,org.elasticsearch.action.admin.cluster.node.info.NodeInfo> getDataNodes()

getAllNodes

public Map<String,org.elasticsearch.action.admin.cluster.node.info.NodeInfo> getAllNodes()

getNodesStats

public Map<String,org.elasticsearch.action.admin.cluster.node.stats.NodeStats> getNodesStats(String... nodesIds)

nodeIdToName

public String nodeIdToName(String nodeId)

nodeIdToHostName

public String nodeIdToHostName(String nodeId)

isConnected

public boolean isConnected()

Check if the Elasticsearch Node is connected and that there are other nodes in the cluster.

Returns:

true if the Elasticsearch client is up and the cluster contains other nodes, false otherwise

isHealthy

public boolean isHealthy()

Check if the cluster health status is not ClusterHealthStatus.RED and that the deflector is up.

Returns:

true if the the cluster is healthy and the deflector is up, false otherwise

isDeflectorHealthy

public boolean isDeflectorHealthy()

Check if the deflector (write index) health status is not ClusterHealthStatus.RED and that the deflector is up.

Returns:

true if the deflector is healthy and up, false otherwise

waitForConnectedAndDeflectorHealthy

public void waitForConnectedAndDeflectorHealthy(long timeout,
                                                TimeUnit unit)
                                         throws InterruptedException,
                                                TimeoutException

Blocks until the Elasticsearch cluster and current write index is healthy again or the given timeout fires.

Parameters:

timeout - the timeout value

unit - the timeout unit

Throws:

InterruptedException

TimeoutException

waitForConnectedAndDeflectorHealthy

public void waitForConnectedAndDeflectorHealthy()
                                         throws InterruptedException,
                                                TimeoutException

Blocks until the Elasticsearch cluster and current write index is healthy again or the default timeout fires.

Throws:

InterruptedException

TimeoutException

updateDataNodeList

public void updateDataNodeList(Map<String,org.elasticsearch.cluster.node.DiscoveryNode> nodes)