Module org.elasticsearch.server
Class TransportNodeUsageStatsForThreadPoolsAction
java.lang.Object
org.elasticsearch.action.support.TransportAction<NodeUsageStatsForThreadPoolsAction.Request,NodeUsageStatsForThreadPoolsAction.Response>
org.elasticsearch.action.support.nodes.TransportNodesAction<NodeUsageStatsForThreadPoolsAction.Request,NodeUsageStatsForThreadPoolsAction.Response,NodeUsageStatsForThreadPoolsAction.NodeRequest,NodeUsageStatsForThreadPoolsAction.NodeResponse,Void>
org.elasticsearch.action.admin.cluster.node.usage.TransportNodeUsageStatsForThreadPoolsAction
public class TransportNodeUsageStatsForThreadPoolsAction
extends TransportNodesAction<NodeUsageStatsForThreadPoolsAction.Request,NodeUsageStatsForThreadPoolsAction.Response,NodeUsageStatsForThreadPoolsAction.NodeRequest,NodeUsageStatsForThreadPoolsAction.NodeResponse,Void>
Collects some thread pool stats from each data node for purposes of shard allocation balancing. The specific stats are defined in
NodeUsageStatsForThreadPools.-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final Stringstatic final ActionType<NodeUsageStatsForThreadPoolsAction.Response> Fields inherited from class org.elasticsearch.action.support.nodes.TransportNodesAction
transportNodeAction, transportServiceFields inherited from class org.elasticsearch.action.support.TransportAction
actionName, taskManager -
Constructor Summary
ConstructorsConstructorDescriptionTransportNodeUsageStatsForThreadPoolsAction(ThreadPool threadPool, ClusterService clusterService, TransportService transportService, ActionFilters actionFilters) -
Method Summary
Modifier and TypeMethodDescriptionnewNodeResponse(StreamInput in, DiscoveryNode node) newResponse(NodeUsageStatsForThreadPoolsAction.Request request, List<NodeUsageStatsForThreadPoolsAction.NodeResponse> nodeResponses, List<FailedNodeException> nodeFailures) Create a newTransportNodesAction.nodeOperation(NodeUsageStatsForThreadPoolsAction.NodeRequest request, Task task) Implements the request recipient logic.Methods inherited from class org.elasticsearch.action.support.nodes.TransportNodesAction
createActionContext, doExecute, newResponseAsync, nodeOperationAsync, resolveRequestMethods inherited from class org.elasticsearch.action.support.TransportAction
execute, executeDirect, localOnly
-
Field Details
-
NAME
- See Also:
-
TYPE
-
-
Constructor Details
-
TransportNodeUsageStatsForThreadPoolsAction
@Inject public TransportNodeUsageStatsForThreadPoolsAction(ThreadPool threadPool, ClusterService clusterService, TransportService transportService, ActionFilters actionFilters)
-
-
Method Details
-
newResponse
protected NodeUsageStatsForThreadPoolsAction.Response newResponse(NodeUsageStatsForThreadPoolsAction.Request request, List<NodeUsageStatsForThreadPoolsAction.NodeResponse> nodeResponses, List<FailedNodeException> nodeFailures) Description copied from class:TransportNodesActionCreate a newTransportNodesAction. This method is executed onTransportNodesAction.finalExecutor.- Specified by:
newResponsein classTransportNodesAction<NodeUsageStatsForThreadPoolsAction.Request,NodeUsageStatsForThreadPoolsAction.Response, NodeUsageStatsForThreadPoolsAction.NodeRequest, NodeUsageStatsForThreadPoolsAction.NodeResponse, 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.nodeResponses- All successful node-level responses.nodeFailures- All node-level failures.- Returns:
- Never
null.
-
newNodeRequest
protected NodeUsageStatsForThreadPoolsAction.NodeRequest newNodeRequest(NodeUsageStatsForThreadPoolsAction.Request request) -
newNodeResponse
protected NodeUsageStatsForThreadPoolsAction.NodeResponse newNodeResponse(StreamInput in, DiscoveryNode node) throws IOException -
nodeOperation
protected NodeUsageStatsForThreadPoolsAction.NodeResponse nodeOperation(NodeUsageStatsForThreadPoolsAction.NodeRequest 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).
-