Package org.elasticsearch.node
Class ResponseCollectorService
org.elasticsearch.node.ResponseCollectorService
- All Implemented Interfaces:
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
Modifier and TypeClassDescriptionstatic class
Struct-like class encapsulating a point-in-time snapshot of a particular node's statistics. -
Field Summary
Modifier and TypeFieldDescriptionstatic double
The weight parameter used for all moving averages of parameters. -
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
nodeId, int queueSize, long responseTimeNanos, long avgServiceTimeNanos)
void
clusterChanged(ClusterChangedEvent event)
Called when cluster state changes.<,> clientSearchConnections)
nodeId)
Optionally return aNodeStatistics
for the given nodeid, if response information exists for the given node.Methods inherited from class java.lang.
, , , , , , , , , ,
-
Field Details
-
ALPHA
public static final double ALPHAThe weight parameter used for all moving averages of parameters.- See Also:
- Constant Field Values
-
-
Constructor Details
-
ResponseCollectorService
-
-
Method Details
-
clusterChanged
Description copied from interface:ClusterStateListener
Called when cluster state changes.- Specified by:
clusterChanged
in interfaceClusterStateListener
-
addNodeStatistics
public void addNodeStatistics( nodeId, int queueSize, long responseTimeNanos, long avgServiceTimeNanos) -
getAllNodeStatistics
-
getAdaptiveStats
public <,> clientSearchConnections) -
getNodeStatistics
public < nodeId)Optionally return aNodeStatistics
for the given nodeid, if response information exists for the given node. Returns an emptyOptional
if the node was not found.
-