public abstract class TransportNodesAction<NodesRequest extends BaseNodesRequest<NodesRequest>,NodesResponse extends BaseNodesResponse,NodeRequest extends BaseNodeRequest,NodeResponse extends BaseNodeResponse> extends HandledTransportAction<NodesRequest,NodesResponse>
Modifier and Type | Field and Description |
---|---|
protected ClusterService |
clusterService |
protected java.lang.Class<NodeResponse> |
nodeResponseClass |
protected TransportService |
transportService |
actionName, indexNameExpressionResolver, taskManager, threadPool
deprecationLogger, logger, settings
Modifier | Constructor and Description |
---|---|
protected |
TransportNodesAction(Settings settings,
java.lang.String actionName,
ThreadPool threadPool,
ClusterService clusterService,
TransportService transportService,
ActionFilters actionFilters,
IndexNameExpressionResolver indexNameExpressionResolver,
java.util.function.Supplier<NodesRequest> request,
java.util.function.Supplier<NodeRequest> nodeRequest,
java.lang.String nodeExecutor,
java.lang.Class<NodeResponse> nodeResponseClass) |
Modifier and Type | Method and Description |
---|---|
protected void |
doExecute(NodesRequest request,
ActionListener<NodesResponse> listener) |
protected void |
doExecute(Task task,
NodesRequest request,
ActionListener<NodesResponse> listener) |
protected abstract NodeRequest |
newNodeRequest(java.lang.String nodeId,
NodesRequest request) |
protected abstract NodeResponse |
newNodeResponse() |
protected NodesResponse |
newResponse(NodesRequest request,
java.util.concurrent.atomic.AtomicReferenceArray nodesResponses)
Map the responses into
nodeResponseClass responses and FailedNodeException s. |
protected abstract NodesResponse |
newResponse(NodesRequest request,
java.util.List<NodeResponse> responses,
java.util.List<FailedNodeException> failures)
Create a new
NodesResponse (multi-node response). |
protected abstract NodeResponse |
nodeOperation(NodeRequest request) |
protected NodeResponse |
nodeOperation(NodeRequest request,
Task task) |
protected void |
resolveRequest(NodesRequest request,
ClusterState clusterState)
resolve node ids to concrete nodes of the incoming request
|
protected boolean |
transportCompress() |
execute, execute, execute, execute
logDeprecatedSetting, logRemovedSetting, nodeName
protected final ClusterService clusterService
protected final TransportService transportService
protected final java.lang.Class<NodeResponse extends BaseNodeResponse> nodeResponseClass
protected TransportNodesAction(Settings settings, java.lang.String actionName, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver, java.util.function.Supplier<NodesRequest> request, java.util.function.Supplier<NodeRequest> nodeRequest, java.lang.String nodeExecutor, java.lang.Class<NodeResponse> nodeResponseClass)
protected final void doExecute(NodesRequest request, ActionListener<NodesResponse> listener)
doExecute
in class TransportAction<NodesRequest extends BaseNodesRequest<NodesRequest>,NodesResponse extends BaseNodesResponse>
protected void doExecute(Task task, NodesRequest request, ActionListener<NodesResponse> listener)
doExecute
in class TransportAction<NodesRequest extends BaseNodesRequest<NodesRequest>,NodesResponse extends BaseNodesResponse>
protected boolean transportCompress()
protected NodesResponse newResponse(NodesRequest request, java.util.concurrent.atomic.AtomicReferenceArray nodesResponses)
nodeResponseClass
responses and FailedNodeException
s.request
- The associated request.nodesResponses
- All node-level responsesnull
.java.lang.NullPointerException
- if nodesResponses
is null
newResponse(BaseNodesRequest, List, List)
protected abstract NodesResponse newResponse(NodesRequest request, java.util.List<NodeResponse> responses, java.util.List<FailedNodeException> failures)
NodesResponse
(multi-node response).request
- The associated request.responses
- All successful node-level responses.failures
- All node-level failures.null
.java.lang.NullPointerException
- if any parameter is null
.protected abstract NodeRequest newNodeRequest(java.lang.String nodeId, NodesRequest request)
protected abstract NodeResponse newNodeResponse()
protected abstract NodeResponse nodeOperation(NodeRequest request)
protected NodeResponse nodeOperation(NodeRequest request, Task task)
protected void resolveRequest(NodesRequest request, ClusterState clusterState)