Field Detail

• transportService

  protected final TransportService transportService

• clusterService

  protected final ClusterService clusterService

• indicesService

  protected final IndicesService indicesService

• shardStateAction

  protected final ShardStateAction shardStateAction

• defaultReplicationType

  protected final ReplicationType defaultReplicationType

• defaultWriteConsistencyLevel

  protected final WriteConsistencyLevel defaultWriteConsistencyLevel

• transportOptions

  protected final TransportRequestOptions transportOptions

Constructor Detail

• TransportShardReplicationOperationAction

  protected TransportShardReplicationOperationAction(Settings settings,
                                                     String actionName,
                                                     TransportService transportService,
                                                     ClusterService clusterService,
                                                     IndicesService indicesService,
                                                     ThreadPool threadPool,
                                                     ShardStateAction shardStateAction,
                                                     ActionFilters actionFilters)

Method Detail

• doExecute

  protected void doExecute(Request request,
                           ActionListener<Response> listener)

• newRequestInstance

  protected abstract Request newRequestInstance()

• newReplicaRequestInstance

  protected abstract ReplicaRequest newReplicaRequestInstance()

• newResponseInstance

  protected abstract Response newResponseInstance()

• executor

  protected abstract String executor()

• shardOperationOnReplica

  protected abstract void shardOperationOnReplica(TransportShardReplicationOperationAction.ReplicaOperationRequest shardRequest)

• shardOperationOnPrimary

  protected abstract Tuple<Response,ReplicaRequest> shardOperationOnPrimary(ClusterState clusterState,
                                                                            TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest)
                                                                     throws Throwable

  Returns:

  A tuple containing not null values, as first value the result of the primary operation and as second value the request to be executed on the replica shards.

  Throws:

  Throwable

• shards

  protected abstract ShardIterator shards(ClusterState clusterState,
                                          TransportShardReplicationOperationAction.InternalRequest request)
                                   throws ElasticsearchException

  Throws:

  ElasticsearchException

• checkWriteConsistency

  protected abstract boolean checkWriteConsistency()

• checkGlobalBlock

  protected ClusterBlockException checkGlobalBlock(ClusterState state)

• checkRequestBlock

  protected ClusterBlockException checkRequestBlock(ClusterState state,
                                                    TransportShardReplicationOperationAction.InternalRequest request)

• resolveIndex

  protected abstract boolean resolveIndex()

• resolveRequest

  protected boolean resolveRequest(ClusterState state,
                                   TransportShardReplicationOperationAction.InternalRequest request,
                                   ActionListener<Response> listener)

  Resolves the request, by default doing nothing. If the resolve means a different execution, then return false here to indicate not to continue and execute this request.

• transportOptions

  protected TransportRequestOptions transportOptions()

• retryPrimaryException

  protected boolean retryPrimaryException(Throwable e)

• ignoreReplicaException

  protected boolean ignoreReplicaException(Throwable e)

  Should an exception be ignored when the operation is performed on the replica.

• isConflictException

  protected boolean isConflictException(Throwable e)

• getIndexShardOperationsCounter

  protected Releasable getIndexShardOperationsCounter(ShardId shardId)