public abstract class TransportInstanceSingleOperationAction<Request extends InstanceShardOperationRequest,Response extends ActionResponse> extends TransportAction<Request,Response>
Modifier and Type | Class and Description |
---|---|
protected class |
TransportInstanceSingleOperationAction.InternalRequest
Internal request class that gets built on each node.
|
Modifier and Type | Field and Description |
---|---|
protected ClusterService |
clusterService |
protected TransportService |
transportService |
actionName, threadPool
componentSettings, logger, settings
Modifier | Constructor and Description |
---|---|
protected |
TransportInstanceSingleOperationAction(Settings settings,
String actionName,
ThreadPool threadPool,
ClusterService clusterService,
TransportService transportService,
ActionFilters actionFilters) |
execute, execute, forceThreadedListener
nodeName
protected final ClusterService clusterService
protected final TransportService transportService
protected TransportInstanceSingleOperationAction(Settings settings, String actionName, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, ActionFilters actionFilters)
protected void doExecute(Request request, ActionListener<Response> listener)
doExecute
in class TransportAction<Request extends InstanceShardOperationRequest,Response extends ActionResponse>
protected abstract String executor()
protected abstract void shardOperation(TransportInstanceSingleOperationAction.InternalRequest request, ActionListener<Response> listener) throws ElasticsearchException
ElasticsearchException
protected abstract Request newRequest()
protected abstract Response newResponse()
protected ClusterBlockException checkGlobalBlock(ClusterState state)
protected ClusterBlockException checkRequestBlock(ClusterState state, TransportInstanceSingleOperationAction.InternalRequest request)
protected abstract boolean resolveRequest(ClusterState state, TransportInstanceSingleOperationAction.InternalRequest request, ActionListener<Response> listener)
protected boolean retryOnFailure(Throwable e)
protected TransportRequestOptions transportOptions()
protected abstract ShardIterator shards(ClusterState clusterState, TransportInstanceSingleOperationAction.InternalRequest request) throws ElasticsearchException
ElasticsearchException
Copyright © 2009–2015. All rights reserved.