Package org.elasticsearch.action.admin.cluster.node.stats

Class TransportNodesStatsAction

java.lang.Object

org.elasticsearch.action.support.TransportAction<Request,Response>

org.elasticsearch.action.support.HandledTransportAction<NodesRequest,NodesResponse>

org.elasticsearch.action.support.nodes.TransportNodesAction<NodesStatsRequest,NodesStatsResponse,TransportNodesStatsAction.NodeStatsRequest,NodeStats>

org.elasticsearch.action.admin.cluster.node.stats.TransportNodesStatsAction

public class TransportNodesStatsAction
extends TransportNodesAction<NodesStatsRequest,NodesStatsResponse,TransportNodesStatsAction.NodeStatsRequest,NodeStats>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TransportNodesStatsAction.NodeStatsRequest

Field Summary

Fields inherited from class org.elasticsearch.action.support.nodes.TransportNodesAction

clusterService, nodeResponseClass, threadPool, transportNodeAction, transportService

Fields inherited from class org.elasticsearch.action.support.TransportAction

actionName, logger, taskManager

Constructor Summary

Constructors

Constructor	Description
TransportNodesStatsAction(ThreadPool threadPool, ClusterService clusterService, TransportService transportService, NodeService nodeService, ActionFilters actionFilters)

Method Summary

Modifier and Type	Method	Description
protected TransportNodesStatsAction.NodeStatsRequest	newNodeRequest(NodesStatsRequest request)
protected NodeStats	newNodeResponse(StreamInput in, DiscoveryNode node)
protected NodesStatsResponse	newResponse(NodesStatsRequest request, List<NodeStats> responses, List<FailedNodeException> failures)	Create a new TransportNodesAction (multi-node response).
protected NodeStats	nodeOperation(TransportNodesStatsAction.NodeStatsRequest nodeStatsRequest, Task task)

Methods inherited from class org.elasticsearch.action.support.nodes.TransportNodesAction

doExecute, getTransportNodeAction, newResponseAsync, resolveRequest

Methods inherited from class org.elasticsearch.action.support.TransportAction

execute

Methods inherited from class java.lang.Object

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

Constructor Details

TransportNodesStatsAction

@Inject
public TransportNodesStatsAction(ThreadPool threadPool,
 ClusterService clusterService,
 TransportService transportService,
 NodeService nodeService,
 ActionFilters actionFilters)

Method Details

newResponse

protected NodesStatsResponse newResponse(NodesStatsRequest request,
 List<NodeStats> responses,
 List<FailedNodeException> failures)

Description copied from class: TransportNodesAction

Create a new TransportNodesAction (multi-node response).

Specified by:

newResponse in class TransportNodesAction<NodesStatsRequest,NodesStatsResponse,TransportNodesStatsAction.NodeStatsRequest,NodeStats>

Parameters:

request - The associated request.

responses - All successful node-level responses.

failures - All node-level failures.

Returns:

Never null.

newNodeRequest

protected TransportNodesStatsAction.NodeStatsRequest newNodeRequest(NodesStatsRequest request)

Specified by:

newNodeRequest in class TransportNodesAction<NodesStatsRequest,NodesStatsResponse,TransportNodesStatsAction.NodeStatsRequest,NodeStats>

newNodeResponse

protected NodeStats newNodeResponse(StreamInput in,
 DiscoveryNode node)
                             throws IOException

Specified by:

newNodeResponse in class TransportNodesAction<NodesStatsRequest,NodesStatsResponse,TransportNodesStatsAction.NodeStatsRequest,NodeStats>

Throws:

IOException

nodeOperation

protected NodeStats nodeOperation(TransportNodesStatsAction.NodeStatsRequest nodeStatsRequest,
 Task task)

Specified by:

nodeOperation in class TransportNodesAction<NodesStatsRequest,NodesStatsResponse,TransportNodesStatsAction.NodeStatsRequest,NodeStats>