public abstract class TransportSingleCustomOperationAction<Request extends SingleCustomOperationRequest,Response extends ActionResponse> extends TransportAction<Request,Response>
Modifier and Type | Class and Description |
---|---|
protected class |
TransportSingleCustomOperationAction.InternalRequest
Internal request class that gets built on each node.
|
protected class |
TransportSingleCustomOperationAction.ShardSingleOperationRequest |
Modifier and Type | Field and Description |
---|---|
protected ClusterService |
clusterService |
protected TransportService |
transportService |
actionName, threadPool
componentSettings, logger, settings
Modifier | Constructor and Description |
---|---|
protected |
TransportSingleCustomOperationAction(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,
TransportSingleCustomOperationAction.InternalRequest request) |
protected void |
doExecute(Request request,
ActionListener<Response> listener) |
protected abstract String |
executor() |
protected abstract Request |
newRequest() |
protected abstract Response |
newResponse() |
protected abstract boolean |
resolveIndex(Request request) |
protected abstract Response |
shardOperation(Request request,
ShardId shardId)
Operation to be executed at the shard level.
|
protected abstract ShardsIterator |
shards(ClusterState state,
TransportSingleCustomOperationAction.InternalRequest request)
Can return null to execute on this local node.
|
execute, execute, forceThreadedListener
nodeName
protected final ClusterService clusterService
protected final TransportService transportService
protected TransportSingleCustomOperationAction(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 SingleCustomOperationRequest,Response extends ActionResponse>
protected abstract String executor()
protected abstract ShardsIterator shards(ClusterState state, TransportSingleCustomOperationAction.InternalRequest request)
protected abstract Response shardOperation(Request request, ShardId shardId) throws ElasticsearchException
ElasticsearchException
protected abstract Request newRequest()
protected abstract Response newResponse()
protected ClusterBlockException checkGlobalBlock(ClusterState state)
protected ClusterBlockException checkRequestBlock(ClusterState state, TransportSingleCustomOperationAction.InternalRequest request)
protected abstract boolean resolveIndex(Request request)
Copyright © 2009–2015. All rights reserved.