Module org.elasticsearch.server

Package org.elasticsearch.cluster

Class InternalClusterInfoService

java.lang.Object

org.elasticsearch.cluster.InternalClusterInfoService

All Implemented Interfaces:

ClusterInfoService, ClusterStateListener

public class InternalClusterInfoService
extends Object
implements ClusterInfoService, ClusterStateListener

InternalClusterInfoService provides the ClusterInfoService interface, routinely updated on a timer. The timer can be dynamically changed by setting the cluster.info.update.interval setting (defaulting to 30 seconds). The InternalClusterInfoService only runs on the master node. Listens for changes in the number of data nodes and immediately submits a ClusterInfoUpdateJob if a node has been added. Every time the timer runs, if cluster.routing.allocation.disk.threshold_enabled is enabled, gathers information about the disk usage and shard sizes across the cluster, computes a new cluster info and notifies the registered listeners. If disk threshold monitoring is disabled, listeners are called with an empty cluster info.

Field Summary

Fields

Modifier and Type	Field	Description
static final Setting<TimeValue>	INTERNAL_CLUSTER_INFO_TIMEOUT_SETTING
static final Setting<TimeValue>	INTERNAL_CLUSTER_INFO_UPDATE_INTERVAL_SETTING

Constructor Summary

Constructors

Constructor	Description
InternalClusterInfoService(Settings settings, ClusterService clusterService, ThreadPool threadPool, Client client)

Method Summary

Modifier and Type	Method	Description
void	addListener(Consumer<ClusterInfo> clusterInfoConsumer)	Add a listener for new cluster information
void	clusterChanged(ClusterChangedEvent event)	Called when cluster state changes.
ClusterInfo	getClusterInfo()

Methods inherited from class java.lang.Object

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

Field Details

INTERNAL_CLUSTER_INFO_UPDATE_INTERVAL_SETTING

public static final Setting<TimeValue> INTERNAL_CLUSTER_INFO_UPDATE_INTERVAL_SETTING

INTERNAL_CLUSTER_INFO_TIMEOUT_SETTING

public static final Setting<TimeValue> INTERNAL_CLUSTER_INFO_TIMEOUT_SETTING

Constructor Details

InternalClusterInfoService

public InternalClusterInfoService(Settings settings,
 ClusterService clusterService,
 ThreadPool threadPool,
 Client client)

Method Details

clusterChanged

public void clusterChanged(ClusterChangedEvent event)

Description copied from interface: ClusterStateListener

Called when cluster state changes.

Cluster states are applied one-by-one which means they can be a performance bottleneck. Implementations of this method should therefore be fast, so please consider forking work into the background rather than doing everything inline.

Specified by:

clusterChanged in interface ClusterStateListener

getClusterInfo

public ClusterInfo getClusterInfo()

Specified by:

getClusterInfo in interface ClusterInfoService

Returns:

the latest cluster information

addListener

public void addListener(Consumer<ClusterInfo> clusterInfoConsumer)

Description copied from interface: ClusterInfoService

Add a listener for new cluster information

Specified by:

addListener in interface ClusterInfoService