public abstract class TransportIndexReplicationOperationAction<Request extends IndexReplicationOperationRequest,Response extends ActionResponse,ShardRequest extends ShardReplicationOperationRequest,ShardReplicaRequest extends ShardReplicationOperationRequest,ShardResponse extends ActionResponse> extends TransportAction<Request,Response>
Modifier and Type | Field and Description |
---|---|
protected ClusterService |
clusterService |
protected TransportShardReplicationOperationAction<ShardRequest,ShardReplicaRequest,ShardResponse> |
shardAction |
actionName, threadPool
componentSettings, logger, settings
Modifier | Constructor and Description |
---|---|
protected |
TransportIndexReplicationOperationAction(Settings settings,
String actionName,
ClusterService clusterService,
ThreadPool threadPool,
TransportShardReplicationOperationAction<ShardRequest,ShardReplicaRequest,ShardResponse> shardAction,
ActionFilters actionFilters) |
Modifier and Type | Method and Description |
---|---|
protected abstract boolean |
accumulateExceptions() |
protected ClusterBlockException |
checkGlobalBlock(ClusterState state,
Request request) |
protected ClusterBlockException |
checkRequestBlock(ClusterState state,
Request request) |
protected void |
doExecute(Request request,
ActionListener<Response> listener) |
protected abstract Response |
newResponseInstance(Request request,
List<ShardResponse> shardResponses,
int failuresCount,
List<ShardOperationFailedException> shardFailures) |
protected abstract ShardRequest |
newShardRequestInstance(Request request,
int shardId) |
protected abstract GroupShardsIterator |
shards(Request request) |
execute, execute, forceThreadedListener
nodeName
protected final ClusterService clusterService
protected final TransportShardReplicationOperationAction<ShardRequest extends ShardReplicationOperationRequest,ShardReplicaRequest extends ShardReplicationOperationRequest,ShardResponse extends ActionResponse> shardAction
protected TransportIndexReplicationOperationAction(Settings settings, String actionName, ClusterService clusterService, ThreadPool threadPool, TransportShardReplicationOperationAction<ShardRequest,ShardReplicaRequest,ShardResponse> shardAction, ActionFilters actionFilters)
protected void doExecute(Request request, ActionListener<Response> listener)
doExecute
in class TransportAction<Request extends IndexReplicationOperationRequest,Response extends ActionResponse>
protected abstract Response newResponseInstance(Request request, List<ShardResponse> shardResponses, int failuresCount, List<ShardOperationFailedException> shardFailures)
protected abstract GroupShardsIterator shards(Request request) throws ElasticsearchException
ElasticsearchException
protected abstract ShardRequest newShardRequestInstance(Request request, int shardId)
protected abstract boolean accumulateExceptions()
protected ClusterBlockException checkGlobalBlock(ClusterState state, Request request)
protected ClusterBlockException checkRequestBlock(ClusterState state, Request request)
Copyright © 2009–2015. All rights reserved.