public abstract class TransportNodesOperationAction<Request extends NodesOperationRequestextends TransportAction ,Response extends NodesOperationResponse ,NodeRequest extends NodeOperationRequest ,NodeResponse extends NodeOperationResponse > <Request ,Response>
| Modifier and Type | Field and Description |
|---|---|
protected ClusterName |
clusterName
|
protected ClusterService |
clusterService
|
protected TransportService |
transportService
|
actionName, threadPoolcomponentSettings, logger, settings| Modifier | Constructor and Description |
|---|---|
protected |
TransportNodesOperationAction(Settings
|
| Modifier and Type | Method and Description |
|---|---|
protected abstract boolean |
accumulateExceptions()
|
protected void |
doExecute(Request request, ActionListener
|
protected abstract String |
executor()
|
protected String |
filterNodeIds(DiscoveryNodes
|
protected abstract NodeRequest |
newNodeRequest()
|
protected abstract NodeRequest |
newNodeRequest(String
|
protected abstract NodeResponse |
newNodeResponse()
|
protected abstract Request |
newRequest()
|
protected abstract Response |
newResponse(Request request, AtomicReferenceArray
|
protected abstract NodeResponse |
nodeOperation(NodeRequest request)
|
protected String |
resolveNodes(Request request, ClusterState
|
protected boolean |
transportCompress()
|
execute, execute, forceThreadedListenernodeNameprotected final ClusterNameclusterName
protected final ClusterServiceclusterService
protected final TransportServicetransportService
protected TransportNodesOperationAction(Settingssettings, String actionName, ClusterName clusterName, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, ActionFilters actionFilters)
protected void doExecute(Request request, ActionListener<Response> listener)
protected boolean transportCompress()
protected abstract Stringexecutor()
protected abstract Request newRequest()
protected abstract Response newResponse(Request request, AtomicReferenceArraynodesResponses)
protected abstract NodeRequest newNodeRequest()
protected abstract NodeRequest newNodeRequest(StringnodeId, 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)
protected String[] resolveNodes(Request request, ClusterState clusterState)