public abstract class TransportShardSingleOperationAction<Request extends SingleShardOperationRequest,Response extends ActionResponse> extends TransportAction<Request,Response>
Modifier and Type | Class and Description |
---|---|
protected class |
TransportShardSingleOperationAction.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 |
TransportShardSingleOperationAction(Settings settings,
String actionName,
ThreadPool threadPool,
ClusterService clusterService,
TransportService transportService,
ActionFilters actionFilters) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
checkGlobalBlock(ClusterState state) |
protected ClusterBlockException |
checkRequestBlock(ClusterState state,
TransportShardSingleOperationAction.InternalRequest request) |
protected void |
doExecute(Request request,
ActionListener<Response> listener) |
protected abstract String |
executor() |
protected boolean |
isSubAction()
Tells whether the action is a main one or a subaction.
|
protected abstract Request |
newRequest() |
protected abstract Response |
newResponse() |
protected abstract boolean |
resolveIndex() |
protected void |
resolveRequest(ClusterState state,
TransportShardSingleOperationAction.InternalRequest request) |
protected abstract Response |
shardOperation(Request request,
ShardId shardId) |
protected abstract ShardIterator |
shards(ClusterState state,
TransportShardSingleOperationAction.InternalRequest request) |
execute, execute, forceThreadedListener
nodeName
protected final ClusterService clusterService
protected final TransportService transportService
protected TransportShardSingleOperationAction(Settings settings, String actionName, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, ActionFilters actionFilters)
protected boolean isSubAction()
protected void doExecute(Request request, ActionListener<Response> listener)
doExecute
in class TransportAction<Request extends SingleShardOperationRequest,Response extends ActionResponse>
protected abstract String executor()
protected abstract Response shardOperation(Request request, ShardId shardId) throws ElasticsearchException
ElasticsearchException
protected abstract Request newRequest()
protected abstract Response newResponse()
protected abstract boolean resolveIndex()
protected ClusterBlockException checkGlobalBlock(ClusterState state)
protected ClusterBlockException checkRequestBlock(ClusterState state, TransportShardSingleOperationAction.InternalRequest request)
protected void resolveRequest(ClusterState state, TransportShardSingleOperationAction.InternalRequest request)
protected abstract ShardIterator shards(ClusterState state, TransportShardSingleOperationAction.InternalRequest request) throws ElasticsearchException
ElasticsearchException
Copyright © 2009–2015. All rights reserved.