public abstract class TransportNodesOperationAction<Request extends NodesOperationRequest,Response extends NodesOperationResponse,NodeRequest extends NodeOperationRequest,NodeResponse extends NodeOperationResponse> extends TransportAction<Request,Response>
Modifier and Type | Field and Description |
---|---|
protected ClusterName |
clusterName |
protected ClusterService |
clusterService |
protected TransportService |
transportService |
actionName, threadPool
componentSettings, logger, settings
Modifier | Constructor and Description |
---|---|
protected |
TransportNodesOperationAction(Settings settings,
String actionName,
ClusterName clusterName,
ThreadPool threadPool,
ClusterService clusterService,
TransportService transportService,
ActionFilters actionFilters) |
Modifier and Type | Method and Description |
---|---|
protected abstract boolean |
accumulateExceptions() |
protected void |
doExecute(Request request,
ActionListener<Response> listener) |
protected abstract String |
executor() |
protected String[] |
filterNodeIds(DiscoveryNodes nodes,
String[] nodesIds) |
protected abstract NodeRequest |
newNodeRequest() |
protected abstract NodeRequest |
newNodeRequest(String nodeId,
Request request) |
protected abstract NodeResponse |
newNodeResponse() |
protected abstract Request |
newRequest() |
protected abstract Response |
newResponse(Request request,
AtomicReferenceArray nodesResponses) |
protected abstract NodeResponse |
nodeOperation(NodeRequest request) |
protected boolean |
transportCompress() |
execute, execute, forceThreadedListener
nodeName
protected final ClusterName clusterName
protected final ClusterService clusterService
protected final TransportService transportService
protected TransportNodesOperationAction(Settings settings, String actionName, ClusterName clusterName, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, ActionFilters actionFilters)
protected void doExecute(Request request, ActionListener<Response> listener)
doExecute
in class TransportAction<Request extends NodesOperationRequest,Response extends NodesOperationResponse>
protected boolean transportCompress()
protected abstract String executor()
protected abstract Request newRequest()
protected abstract Response newResponse(Request request, AtomicReferenceArray nodesResponses)
protected abstract NodeRequest newNodeRequest()
protected abstract NodeRequest newNodeRequest(String nodeId, Request request)
protected abstract NodeResponse newNodeResponse()
protected abstract NodeResponse nodeOperation(NodeRequest request) throws ElasticsearchException
ElasticsearchException
protected abstract boolean accumulateExceptions()
protected String[] filterNodeIds(DiscoveryNodes nodes, String[] nodesIds)
Copyright © 2009–2015. All rights reserved.