Package org.elasticsearch.node

Class ResponseCollectorService

java.lang.Object

org.elasticsearch.node.ResponseCollectorService

All Implemented Interfaces:

ClusterStateListener

public final class ResponseCollectorService
extends Object
implements ClusterStateListener

Collects statistics about queue size, response time, and service time of tasks executed on each node, making the EWMA of the values available to the coordinating node.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ResponseCollectorService.ComputedNodeStats	Struct-like class encapsulating a point-in-time snapshot of a particular node's statistics.

Field Summary

Fields

Modifier and Type	Field	Description
static final double	ALPHA	The weight parameter used for all moving averages of parameters.

Constructor Summary

Constructors

Constructor	Description
ResponseCollectorService(ClusterService clusterService)

Method Summary

Modifier and Type	Method	Description
void	addNodeStatistics(String nodeId, int queueSize, long responseTimeNanos, long avgServiceTimeNanos)
void	clusterChanged(ClusterChangedEvent event)	Called when cluster state changes.
AdaptiveSelectionStats	getAdaptiveStats(Map<String,Long> clientSearchConnections)
Map<String,ResponseCollectorService.ComputedNodeStats>	getAllNodeStatistics()
Optional<ResponseCollectorService.ComputedNodeStats>	getNodeStatistics(String nodeId)	Optionally return a NodeStatistics for the given nodeid, if response information exists for the given node.

Methods inherited from class java.lang.Object

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

Field Details

ALPHA

public static final double ALPHA

The weight parameter used for all moving averages of parameters.

See Also:

• Constant Field Values

Constructor Details

ResponseCollectorService

public ResponseCollectorService(ClusterService clusterService)

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

addNodeStatistics

public void addNodeStatistics(String nodeId,
 int queueSize,
 long responseTimeNanos,
 long avgServiceTimeNanos)

getAllNodeStatistics

public Map<String,ResponseCollectorService.ComputedNodeStats> getAllNodeStatistics()

getAdaptiveStats

public AdaptiveSelectionStats getAdaptiveStats(Map<String,Long> clientSearchConnections)

getNodeStatistics

public Optional<ResponseCollectorService.ComputedNodeStats> getNodeStatistics(String nodeId)

Optionally return a NodeStatistics for the given nodeid, if response information exists for the given node. Returns an empty Optional if the node was not found.