public abstract class TransportShardReplicationOperationAction<Request extends ShardReplicationOperationRequest,ReplicaRequest extends ShardReplicationOperationRequest,Response extends ActionResponse> extends TransportAction<Request,Response>
Modifier and Type | Class and Description |
---|---|
protected class |
TransportShardReplicationOperationAction.AsyncShardOperationAction |
protected class |
TransportShardReplicationOperationAction.InternalRequest
Internal request class that gets built on each node.
|
protected class |
TransportShardReplicationOperationAction.PrimaryOperationRequest |
static class |
TransportShardReplicationOperationAction.PrimaryResponse<Response,ReplicaRequest> |
protected class |
TransportShardReplicationOperationAction.ReplicaOperationRequest |
Modifier and Type | Field and Description |
---|---|
protected ClusterService |
clusterService |
protected ReplicationType |
defaultReplicationType |
protected WriteConsistencyLevel |
defaultWriteConsistencyLevel |
protected IndicesService |
indicesService |
protected ShardStateAction |
shardStateAction |
protected TransportRequestOptions |
transportOptions |
protected TransportService |
transportService |
actionName, threadPool
componentSettings, logger, settings
Modifier | Constructor and Description |
---|---|
protected |
TransportShardReplicationOperationAction(Settings settings,
String actionName,
TransportService transportService,
ClusterService clusterService,
IndicesService indicesService,
ThreadPool threadPool,
ShardStateAction shardStateAction,
ActionFilters actionFilters) |
execute, execute, forceThreadedListener
nodeName
protected final TransportService transportService
protected final ClusterService clusterService
protected final IndicesService indicesService
protected final ShardStateAction shardStateAction
protected final ReplicationType defaultReplicationType
protected final WriteConsistencyLevel defaultWriteConsistencyLevel
protected final TransportRequestOptions transportOptions
protected TransportShardReplicationOperationAction(Settings settings, String actionName, TransportService transportService, ClusterService clusterService, IndicesService indicesService, ThreadPool threadPool, ShardStateAction shardStateAction, ActionFilters actionFilters)
protected void doExecute(Request request, ActionListener<Response> listener)
doExecute
in class TransportAction<Request extends ShardReplicationOperationRequest,Response extends ActionResponse>
protected abstract Request newRequestInstance()
protected abstract ReplicaRequest newReplicaRequestInstance()
protected abstract Response newResponseInstance()
protected abstract String executor()
protected abstract TransportShardReplicationOperationAction.PrimaryResponse<Response,ReplicaRequest> shardOperationOnPrimary(ClusterState clusterState, TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest) throws Throwable
Throwable
protected abstract void shardOperationOnReplica(TransportShardReplicationOperationAction.ReplicaOperationRequest shardRequest)
protected void postPrimaryOperation(TransportShardReplicationOperationAction.InternalRequest request, TransportShardReplicationOperationAction.PrimaryResponse<Response,ReplicaRequest> response)
protected abstract ShardIterator shards(ClusterState clusterState, TransportShardReplicationOperationAction.InternalRequest request) throws ElasticsearchException
ElasticsearchException
protected abstract boolean checkWriteConsistency()
protected ClusterBlockException checkGlobalBlock(ClusterState state)
protected ClusterBlockException checkRequestBlock(ClusterState state, TransportShardReplicationOperationAction.InternalRequest request)
protected abstract boolean resolveIndex()
protected boolean resolveRequest(ClusterState state, TransportShardReplicationOperationAction.InternalRequest request, ActionListener<Response> listener)
protected TransportRequestOptions transportOptions()
protected boolean ignoreReplicas()
protected boolean retryPrimaryException(Throwable e)
protected boolean ignoreReplicaException(Throwable e)
protected boolean isConflictException(Throwable e)
Copyright © 2009–2015. All rights reserved.