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

Class TransportClusterStatsAction

java.lang.Object

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

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

org.elasticsearch.action.support.nodes.TransportNodesAction<ClusterStatsRequest,ClusterStatsResponse,TransportClusterStatsAction.ClusterStatsNodeRequest,ClusterStatsNodeResponse>

org.elasticsearch.action.admin.cluster.stats.TransportClusterStatsAction

public class TransportClusterStatsAction
extends TransportNodesAction<ClusterStatsRequest,ClusterStatsResponse,TransportClusterStatsAction.ClusterStatsNodeRequest,ClusterStatsNodeResponse>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TransportClusterStatsAction.ClusterStatsNodeRequest

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, localConnection, logger, taskManager

Constructor Summary

Constructors

Constructor	Description
TransportClusterStatsAction(ThreadPool threadPool, ClusterService clusterService, TransportService transportService, NodeService nodeService, IndicesService indicesService, ActionFilters actionFilters)

Method Summary

Modifier and Type	Method	Description
protected TransportClusterStatsAction.ClusterStatsNodeRequest	newNodeRequest(ClusterStatsRequest request)
protected ClusterStatsNodeResponse	newNodeResponse(StreamInput in)
protected ClusterStatsResponse	newResponse(ClusterStatsRequest request, List<ClusterStatsNodeResponse> responses, List<FailedNodeException> failures)	Create a new TransportNodesAction (multi-node response).
protected void	newResponseAsync(Task task, ClusterStatsRequest request, List<ClusterStatsNodeResponse> responses, List<FailedNodeException> failures, ActionListener<ClusterStatsResponse> listener)	Create a new TransportNodesAction, possibly asynchronously.
protected ClusterStatsNodeResponse	nodeOperation(TransportClusterStatsAction.ClusterStatsNodeRequest nodeRequest)
protected ClusterStatsNodeResponse	nodeOperation(TransportClusterStatsAction.ClusterStatsNodeRequest nodeRequest, Task task)

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

doExecute, getTransportNodeAction, resolveRequest

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

execute, execute, execute

Methods inherited from class java.lang.Object

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

Constructor Details

TransportClusterStatsAction

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

Method Details

newResponseAsync

protected void newResponseAsync(Task task,
 ClusterStatsRequest request,
 List<ClusterStatsNodeResponse> responses,
 List<FailedNodeException> failures,
 ActionListener<ClusterStatsResponse> listener)

Description copied from class: TransportNodesAction

Create a new TransportNodesAction, possibly asynchronously. The default implementation is synchronous and calls TransportNodesAction.newResponse(BaseNodesRequest, List, List)

Overrides:

newResponseAsync in class TransportNodesAction<ClusterStatsRequest,ClusterStatsResponse,TransportClusterStatsAction.ClusterStatsNodeRequest,ClusterStatsNodeResponse>

newResponse

protected ClusterStatsResponse newResponse(ClusterStatsRequest request,
 List<ClusterStatsNodeResponse> responses,
 List<FailedNodeException> failures)

Description copied from class: TransportNodesAction

Create a new TransportNodesAction (multi-node response).

Specified by:

newResponse in class TransportNodesAction<ClusterStatsRequest,ClusterStatsResponse,TransportClusterStatsAction.ClusterStatsNodeRequest,ClusterStatsNodeResponse>

Parameters:

request - The associated request.

responses - All successful node-level responses.

failures - All node-level failures.

Returns:

Never null.

newNodeRequest

protected TransportClusterStatsAction.ClusterStatsNodeRequest newNodeRequest(ClusterStatsRequest request)

Specified by:

newNodeRequest in class TransportNodesAction<ClusterStatsRequest,ClusterStatsResponse,TransportClusterStatsAction.ClusterStatsNodeRequest,ClusterStatsNodeResponse>

newNodeResponse

protected ClusterStatsNodeResponse newNodeResponse(StreamInput in)
                                            throws IOException

Specified by:

newNodeResponse in class TransportNodesAction<ClusterStatsRequest,ClusterStatsResponse,TransportClusterStatsAction.ClusterStatsNodeRequest,ClusterStatsNodeResponse>

Throws:

IOException

nodeOperation

protected ClusterStatsNodeResponse nodeOperation(TransportClusterStatsAction.ClusterStatsNodeRequest nodeRequest)

Specified by:

nodeOperation in class TransportNodesAction<ClusterStatsRequest,ClusterStatsResponse,TransportClusterStatsAction.ClusterStatsNodeRequest,ClusterStatsNodeResponse>

nodeOperation

protected ClusterStatsNodeResponse nodeOperation(TransportClusterStatsAction.ClusterStatsNodeRequest nodeRequest,
 Task task)

Overrides:

nodeOperation in class TransportNodesAction<ClusterStatsRequest,ClusterStatsResponse,TransportClusterStatsAction.ClusterStatsNodeRequest,ClusterStatsNodeResponse>