Module org.elasticsearch.server
Package org.elasticsearch.health.stats
Class HealthApiStatsTransportAction
java.lang.Object
org.elasticsearch.action.support.TransportAction<HealthApiStatsAction.Request,HealthApiStatsAction.Response>
org.elasticsearch.action.support.nodes.TransportNodesAction<HealthApiStatsAction.Request,HealthApiStatsAction.Response,HealthApiStatsAction.Request.Node,HealthApiStatsAction.Response.Node,Void>
org.elasticsearch.health.stats.HealthApiStatsTransportAction
public class HealthApiStatsTransportAction
extends TransportNodesAction<HealthApiStatsAction.Request,HealthApiStatsAction.Response,HealthApiStatsAction.Request.Node,HealthApiStatsAction.Response.Node,Void>
Performs the health api stats operation.
-
Field Summary
Fields inherited from class org.elasticsearch.action.support.nodes.TransportNodesAction
clusterService, transportNodeAction, transportServiceFields inherited from class org.elasticsearch.action.support.TransportAction
actionName, taskManager -
Constructor Summary
ConstructorsConstructorDescriptionHealthApiStatsTransportAction(TransportService transportService, ClusterService clusterService, ThreadPool threadPool, ActionFilters actionFilters, HealthApiStats healthApiStats) -
Method Summary
Modifier and TypeMethodDescriptionprotected HealthApiStatsAction.Request.Nodeprotected HealthApiStatsAction.Response.NodenewNodeResponse(StreamInput in, DiscoveryNode node) protected HealthApiStatsAction.ResponsenewResponse(HealthApiStatsAction.Request request, List<HealthApiStatsAction.Response.Node> nodes, List<FailedNodeException> failures) Create a newTransportNodesAction.protected HealthApiStatsAction.Response.NodenodeOperation(HealthApiStatsAction.Request.Node request, Task task) Implements the request recipient logic.Methods inherited from class org.elasticsearch.action.support.nodes.TransportNodesAction
createActionContext, doExecute, newResponseAsync, nodeOperationAsync, resolveRequest, sendLegacyNodesRequestHeader, skipLegacyNodesRequestHeaderMethods inherited from class org.elasticsearch.action.support.TransportAction
execute, executeDirect, localOnly
-
Constructor Details
-
HealthApiStatsTransportAction
@Inject public HealthApiStatsTransportAction(TransportService transportService, ClusterService clusterService, ThreadPool threadPool, ActionFilters actionFilters, HealthApiStats healthApiStats)
-
-
Method Details
-
newResponse
protected HealthApiStatsAction.Response newResponse(HealthApiStatsAction.Request request, List<HealthApiStatsAction.Response.Node> nodes, List<FailedNodeException> failures) Description copied from class:TransportNodesActionCreate a newTransportNodesAction. This method is executed onTransportNodesAction.finalExecutor.- Specified by:
newResponsein classTransportNodesAction<HealthApiStatsAction.Request,HealthApiStatsAction.Response, HealthApiStatsAction.Request.Node, HealthApiStatsAction.Response.Node, Void> - 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.nodes- All successful node-level responses.failures- All node-level failures.- Returns:
- Never
null.
-
newNodeRequest
-
newNodeResponse
protected HealthApiStatsAction.Response.Node newNodeResponse(StreamInput in, DiscoveryNode node) throws IOException -
nodeOperation
protected HealthApiStatsAction.Response.Node nodeOperation(HealthApiStatsAction.Request.Node request, Task task) Description copied from class:TransportNodesActionImplements the request recipient logic. If access to the request listener is needed, overrideTransportNodesAction.nodeOperationAsync(TransportRequest, Task, ActionListener).
-