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(io.searchbox.client.JestClient jestClient, IndexSetRegistry indexSetRegistry, ScheduledExecutorService scheduler, com.github.joschi.jadconfig.util.Duration requestTimeout)

Method Summary

Modifier and Type	Method and Description
Optional<com.fasterxml.jackson.databind.JsonNode>	deflectorHealth() Requests the cluster health for the current write index.
Set<NodeFileDescriptorStats>	getFileDescriptorStats()
Optional<com.fasterxml.jackson.databind.JsonNode>	health() Requests the cluster health for all indices managed by Graylog.
boolean	isConnected() Check if Elasticsearch is available and that there are data nodes in the cluster.
boolean	isDeflectorHealthy() Check if the deflector (write index) health status is not RED and that the deflector is up.
boolean	isHealthy() Check if the cluster health status is not RED and that the deflector is up.
Optional<String>	nodeIdToHostName(String nodeId)
Optional<String>	nodeIdToName(String nodeId)
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(io.searchbox.client.JestClient jestClient,
                       IndexSetRegistry indexSetRegistry,
                       @Named(value="daemonScheduler")
                       ScheduledExecutorService scheduler,
                       @Named(value="elasticsearch_request_timeout")
                       com.github.joschi.jadconfig.util.Duration requestTimeout)

Method Detail

health

public Optional<com.fasterxml.jackson.databind.JsonNode> health()

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

Returns:

the cluster health response

deflectorHealth

public Optional<com.fasterxml.jackson.databind.JsonNode> 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

getFileDescriptorStats

public Set<NodeFileDescriptorStats> getFileDescriptorStats()

nodeIdToName

public Optional<String> nodeIdToName(String nodeId)

nodeIdToHostName

public Optional<String> nodeIdToHostName(String nodeId)

isConnected

public boolean isConnected()

Check if Elasticsearch is available and that there are data nodes in the cluster.

Returns:

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

isHealthy

public boolean isHealthy()

Check if the cluster health status is not 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 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