Package org.elasticsearch.action.support.replication

Class TransportWriteAction<Request extends ReplicatedWriteRequest<Request>,ReplicaRequest extends ReplicatedWriteRequest<ReplicaRequest>,Response extends ReplicationResponse & WriteResponse>

java.lang.Object

org.elasticsearch.action.support.TransportAction<Request,Response>

org.elasticsearch.action.support.replication.TransportReplicationAction<Request,ReplicaRequest,Response>

org.elasticsearch.action.support.replication.TransportWriteAction<Request,ReplicaRequest,Response>

Direct Known Subclasses:

RetentionLeaseSyncAction, TransportResyncReplicationAction, TransportShardBulkAction

public abstract class TransportWriteAction<Request extends ReplicatedWriteRequest<Request>,ReplicaRequest extends ReplicatedWriteRequest<ReplicaRequest>,Response extends ReplicationResponse & WriteResponse>
extends TransportReplicationAction<Request,ReplicaRequest,Response>

Base class for transport actions that modify data in some shard like index, delete, and shardBulk. Allows performing async actions (e.g. refresh) after performing write operations on primary and replica shards

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TransportWriteAction.WritePrimaryResult<ReplicaRequest extends ReplicatedWriteRequest<ReplicaRequest>,Response extends ReplicationResponse & WriteResponse>	Result of taking the action on the primary.
static class	TransportWriteAction.WriteReplicaResult<ReplicaRequest extends ReplicatedWriteRequest<ReplicaRequest>>	Result of taking the action on the replica.

Nested classes/interfaces inherited from class org.elasticsearch.action.support.replication.TransportReplicationAction

TransportReplicationAction.ConcreteReplicaRequest<R extends TransportRequest>, TransportReplicationAction.ConcreteShardRequest<R extends TransportRequest>, TransportReplicationAction.PrimaryResult<ReplicaRequest extends ReplicationRequest<ReplicaRequest>,Response extends ReplicationResponse>, TransportReplicationAction.ReplicaResponse, TransportReplicationAction.ReplicaResult, TransportReplicationAction.ReplicasProxy, TransportReplicationAction.RetryOnReplicaException

Field Summary

Fields inherited from class org.elasticsearch.action.support.replication.TransportReplicationAction

clusterService, executor, indicesService, shardStateAction, threadPool, transportOptions, transportPrimaryAction, transportReplicaAction, transportService

Fields inherited from class org.elasticsearch.action.support.TransportAction

actionName, logger, taskManager

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TransportWriteAction(Settings settings, java.lang.String actionName, TransportService transportService, ClusterService clusterService, IndicesService indicesService, ThreadPool threadPool, ShardStateAction shardStateAction, ActionFilters actionFilters, Writeable.Reader<Request> request, Writeable.Reader<ReplicaRequest> replicaRequest, java.lang.String executor, boolean forceExecutionOnPrimary)

Method Summary

Modifier and Type	Method	Description
protected ClusterBlockLevel	globalBlockLevel()	Cluster level block to check before request execution.
ClusterBlockLevel	indexBlockLevel()	Index level block to check before request execution.
static Translog.Location	locationToSync(Translog.Location current, Translog.Location next)
protected ReplicationOperation.Replicas<ReplicaRequest>	newReplicasProxy()
protected abstract void	shardOperationOnPrimary(Request request, IndexShard primary, ActionListener<TransportReplicationAction.PrimaryResult<ReplicaRequest,Response>> listener)	Called on the primary with a reference to the primary IndexShard to modify.
protected abstract TransportWriteAction.WriteReplicaResult<ReplicaRequest>	shardOperationOnReplica(ReplicaRequest request, IndexShard replica)	Called once per replica with a reference to the replica IndexShard to modify.
protected static Translog.Location	syncOperationResultOrThrow(Engine.Result operationResult, Translog.Location currentLocation)	Syncs operation result to the translog or throws a shard not available failure

Methods inherited from class org.elasticsearch.action.support.replication.TransportReplicationAction

acquirePrimaryOperationPermit, acquireReplicaOperationPermit, adaptResponse, doExecute, handleOperationRequest, handlePrimaryRequest, handleReplicaRequest, newResponseInstance, resolveRequest, retryPrimaryException, transportOptions, wrapResponseActionListener

Methods inherited from class org.elasticsearch.action.support.TransportAction

execute, execute, execute

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TransportWriteAction

protected TransportWriteAction(Settings settings, java.lang.String actionName, TransportService transportService, ClusterService clusterService, IndicesService indicesService, ThreadPool threadPool, ShardStateAction shardStateAction, ActionFilters actionFilters, Writeable.Reader<Request> request, Writeable.Reader<ReplicaRequest> replicaRequest, java.lang.String executor, boolean forceExecutionOnPrimary)

Method Details

syncOperationResultOrThrow

protected static Translog.Location syncOperationResultOrThrow(Engine.Result operationResult, Translog.Location currentLocation) throws java.lang.Exception

Syncs operation result to the translog or throws a shard not available failure

Throws:

java.lang.Exception

locationToSync

public static Translog.Location locationToSync(Translog.Location current, Translog.Location next)

newReplicasProxy

protected ReplicationOperation.Replicas<ReplicaRequest> newReplicasProxy()

Overrides:

newReplicasProxy in class TransportReplicationAction<Request extends ReplicatedWriteRequest<Request>,ReplicaRequest extends ReplicatedWriteRequest<ReplicaRequest>,Response extends ReplicationResponse & WriteResponse>

shardOperationOnPrimary

protected abstract void shardOperationOnPrimary(Request request, IndexShard primary, ActionListener<TransportReplicationAction.PrimaryResult<ReplicaRequest,Response>> listener)

Called on the primary with a reference to the primary IndexShard to modify.

Specified by:

shardOperationOnPrimary in class TransportReplicationAction<Request extends ReplicatedWriteRequest<Request>,ReplicaRequest extends ReplicatedWriteRequest<ReplicaRequest>,Response extends ReplicationResponse & WriteResponse>

Parameters:

listener - listener for the result of the operation on primary, including current translog location and operation response and failure async refresh is performed on the primary shard according to the Request refresh policy

request - the request to the primary shard

primary - the primary shard to perform the operation on

shardOperationOnReplica

protected abstract TransportWriteAction.WriteReplicaResult<ReplicaRequest> shardOperationOnReplica(ReplicaRequest request, IndexShard replica) throws java.lang.Exception

Called once per replica with a reference to the replica IndexShard to modify.

Specified by:

shardOperationOnReplica in class TransportReplicationAction<Request extends ReplicatedWriteRequest<Request>,ReplicaRequest extends ReplicatedWriteRequest<ReplicaRequest>,Response extends ReplicationResponse & WriteResponse>

Parameters:

request - the request to the replica shard

replica - the replica shard to perform the operation on

Returns:

the result of the operation on replica, including current translog location and operation response and failure async refresh is performed on the replica shard according to the ReplicaRequest refresh policy

Throws:

java.lang.Exception

globalBlockLevel

protected ClusterBlockLevel globalBlockLevel()

Description copied from class: TransportReplicationAction

Cluster level block to check before request execution. Returning null means that no blocks need to be checked.

Overrides:

globalBlockLevel in class TransportReplicationAction<Request extends ReplicatedWriteRequest<Request>,ReplicaRequest extends ReplicatedWriteRequest<ReplicaRequest>,Response extends ReplicationResponse & WriteResponse>

indexBlockLevel

public ClusterBlockLevel indexBlockLevel()

Description copied from class: TransportReplicationAction

Index level block to check before request execution. Returning null means that no blocks need to be checked.

Overrides:

indexBlockLevel in class TransportReplicationAction<Request extends ReplicatedWriteRequest<Request>,ReplicaRequest extends ReplicatedWriteRequest<ReplicaRequest>,Response extends ReplicationResponse & WriteResponse>