Module org.elasticsearch.server
Class TransportNodesInfoAction
java.lang.Object
org.elasticsearch.action.support.TransportAction<NodesInfoRequest,NodesInfoResponse>
org.elasticsearch.action.support.nodes.TransportNodesAction<NodesInfoRequest,NodesInfoResponse,TransportNodesInfoAction.NodeInfoRequest,NodeInfo,Void>
org.elasticsearch.action.admin.cluster.node.info.TransportNodesInfoAction
public class TransportNodesInfoAction
extends TransportNodesAction<NodesInfoRequest,NodesInfoResponse,TransportNodesInfoAction.NodeInfoRequest,NodeInfo,Void>
-
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
ConstructorsConstructorDescriptionTransportNodesInfoAction(ThreadPool threadPool, ClusterService clusterService, TransportService transportService, NodeService nodeService, ActionFilters actionFilters) -
Method Summary
Modifier and TypeMethodDescriptionprotected TransportNodesInfoAction.NodeInfoRequestnewNodeRequest(NodesInfoRequest request) protected NodeInfonewNodeResponse(StreamInput in, DiscoveryNode node) protected NodesInfoResponsenewResponse(NodesInfoRequest nodesInfoRequest, List<NodeInfo> responses, List<FailedNodeException> failures) Create a newTransportNodesAction.protected NodeInfonodeOperation(TransportNodesInfoAction.NodeInfoRequest nodeRequest, 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
-
TYPE
-
-
Constructor Details
-
TransportNodesInfoAction
@Inject public TransportNodesInfoAction(ThreadPool threadPool, ClusterService clusterService, TransportService transportService, NodeService nodeService, ActionFilters actionFilters)
-
-
Method Details
-
newResponse
protected NodesInfoResponse newResponse(NodesInfoRequest nodesInfoRequest, List<NodeInfo> responses, List<FailedNodeException> failures) Description copied from class:TransportNodesActionCreate a newTransportNodesAction. This method is executed onTransportNodesAction.finalExecutor.- Specified by:
newResponsein classTransportNodesAction<NodesInfoRequest,NodesInfoResponse, TransportNodesInfoAction.NodeInfoRequest, NodeInfo, Void> - Parameters:
nodesInfoRequest- 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.
-
newNodeRequest
- Specified by:
newNodeRequestin classTransportNodesAction<NodesInfoRequest,NodesInfoResponse, TransportNodesInfoAction.NodeInfoRequest, NodeInfo, Void>
-
newNodeResponse
- Specified by:
newNodeResponsein classTransportNodesAction<NodesInfoRequest,NodesInfoResponse, TransportNodesInfoAction.NodeInfoRequest, NodeInfo, Void> - Throws:
IOException
-
nodeOperation
Description copied from class:TransportNodesActionImplements the request recipient logic. If access to the request listener is needed, overrideTransportNodesAction.nodeOperationAsync(TransportRequest, Task, ActionListener).- Specified by:
nodeOperationin classTransportNodesAction<NodesInfoRequest,NodesInfoResponse, TransportNodesInfoAction.NodeInfoRequest, NodeInfo, Void>
-