Module org.elasticsearch.server
Class TransportNodesStatsAction
java.lang.Object
org.elasticsearch.action.support.TransportAction<NodesStatsRequest,NodesStatsResponse>
org.elasticsearch.action.support.nodes.TransportNodesAction<NodesStatsRequest,NodesStatsResponse,TransportNodesStatsAction.NodeStatsRequest,NodeStats,SubscribableListener<TransportGetAllocationStatsAction.Response>>
org.elasticsearch.action.admin.cluster.node.stats.TransportNodesStatsAction
public class TransportNodesStatsAction
extends TransportNodesAction<NodesStatsRequest,NodesStatsResponse,TransportNodesStatsAction.NodeStatsRequest,NodeStats,SubscribableListener<TransportGetAllocationStatsAction.Response>>
-
Nested Class Summary
Nested Classes -
Field Summary
FieldsFields inherited from class org.elasticsearch.action.support.nodes.TransportNodesAction
clusterService, transportNodeAction, transportServiceFields inherited from class org.elasticsearch.action.support.TransportAction
actionName, taskManager -
Constructor Summary
ConstructorsConstructorDescriptionTransportNodesStatsAction(ThreadPool threadPool, ClusterService clusterService, TransportService transportService, ActionFilters actionFilters, NodeService nodeService, NodeClient client) -
Method Summary
Modifier and TypeMethodDescriptioncreateActionContext(Task task, NodesStatsRequest request) Create an (optional)TransportNodesAction: called when starting to execute this action, and the result passed toTransportNodesAction.newResponseAsync(org.elasticsearch.tasks.Task, NodesRequest, ActionContext, java.util.List<NodeResponse>, java.util.List<org.elasticsearch.action.FailedNodeException>, org.elasticsearch.action.ActionListener<NodesResponse>)on completion.newNodeRequest(NodesStatsRequest request) protected NodeStatsnewNodeResponse(StreamInput in, DiscoveryNode node) protected NodesStatsResponsenewResponse(NodesStatsRequest request, List<NodeStats> responses, List<FailedNodeException> failures) Create a newTransportNodesAction.protected voidnewResponseAsync(Task task, NodesStatsRequest request, SubscribableListener<TransportGetAllocationStatsAction.Response> actionContext, List<NodeStats> responses, List<FailedNodeException> failures, ActionListener<NodesStatsResponse> listener) Create a newTransportNodesAction, possibly asynchronously.protected NodeStatsnodeOperation(TransportNodesStatsAction.NodeStatsRequest request, Task task) Implements the request recipient logic.Methods inherited from class org.elasticsearch.action.support.nodes.TransportNodesAction
doExecute, nodeOperationAsync, resolveRequestMethods inherited from class org.elasticsearch.action.support.TransportAction
execute, executeDirect, localOnly
-
Field Details
-
TYPE
-
-
Constructor Details
-
TransportNodesStatsAction
@Inject public TransportNodesStatsAction(ThreadPool threadPool, ClusterService clusterService, TransportService transportService, ActionFilters actionFilters, NodeService nodeService, NodeClient client)
-
-
Method Details
-
newResponse
protected NodesStatsResponse newResponse(NodesStatsRequest request, List<NodeStats> responses, List<FailedNodeException> failures) Description copied from class:TransportNodesActionCreate a newTransportNodesAction. This method is executed onTransportNodesAction.finalExecutor.- Specified by:
newResponsein classTransportNodesAction<NodesStatsRequest,NodesStatsResponse, TransportNodesStatsAction.NodeStatsRequest, NodeStats, SubscribableListener<TransportGetAllocationStatsAction.Response>> - Parameters:
request- The request whose response we are constructing.TransportNodesActionmay have already released all its references to this object before calling this method, so it's up to individual implementations to retain their own reference to the request if still needed here.responses- All successful node-level responses.failures- All node-level failures.- Returns:
- Never
null.
-
createActionContext
protected SubscribableListener<TransportGetAllocationStatsAction.Response> createActionContext(Task task, NodesStatsRequest request) Description copied from class:TransportNodesActionCreate an (optional)TransportNodesAction: called when starting to execute this action, and the result passed toTransportNodesAction.newResponseAsync(org.elasticsearch.tasks.Task, NodesRequest, ActionContext, java.util.List<NodeResponse>, java.util.List<org.elasticsearch.action.FailedNodeException>, org.elasticsearch.action.ActionListener<NodesResponse>)on completion. NB runs on the transport worker thread, must not do anything expensive without dispatching to a different executor. -
newResponseAsync
protected void newResponseAsync(Task task, NodesStatsRequest request, SubscribableListener<TransportGetAllocationStatsAction.Response> actionContext, List<NodeStats> responses, List<FailedNodeException> failures, ActionListener<NodesStatsResponse> listener) Description copied from class:TransportNodesActionCreate a newTransportNodesAction, possibly asynchronously. The default implementation is synchronous and callsTransportNodesAction.newResponse(BaseNodesRequest, List, List). This method is executed onTransportNodesAction.finalExecutor.- Overrides:
newResponseAsyncin classTransportNodesAction<NodesStatsRequest,NodesStatsResponse, TransportNodesStatsAction.NodeStatsRequest, NodeStats, SubscribableListener<TransportGetAllocationStatsAction.Response>> - Parameters:
request- The request whose response we are constructing.TransportNodesActionmay have already released all its references to this object before calling this method, so it's up to individual implementations to retain their own reference to the request if still needed here.
-
newNodeRequest
-
newNodeResponse
-
nodeOperation
Description copied from class:TransportNodesActionImplements the request recipient logic. If access to the request listener is needed, overrideTransportNodesAction.nodeOperationAsync(TransportRequest, Task, ActionListener).
-