Package org.elasticsearch.action.resync

Class TransportResyncReplicationAction

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<ResyncReplicationRequest,ResyncReplicationRequest,ResyncReplicationResponse>

org.elasticsearch.action.resync.TransportResyncReplicationAction

All Implemented Interfaces:

PrimaryReplicaSyncer.SyncAction

public class TransportResyncReplicationAction
extends TransportWriteAction<ResyncReplicationRequest,ResyncReplicationRequest,ResyncReplicationResponse>
implements PrimaryReplicaSyncer.SyncAction

Nested Class Summary

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

TransportWriteAction.WritePrimaryResult<ReplicaRequest extends ReplicatedWriteRequest<ReplicaRequest>,Response extends ReplicationResponse & WriteResponse>, TransportWriteAction.WriteReplicaResult<ReplicaRequest extends ReplicatedWriteRequest<ReplicaRequest>>

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, indexNameExpressionResolver, indicesService, shardStateAction, threadPool, transportOptions, transportPrimaryAction, transportReplicaAction, transportService

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

actionName, logger, taskManager

Constructor Summary

Constructors

Constructor	Description
TransportResyncReplicationAction(Settings settings, TransportService transportService, ClusterService clusterService, IndicesService indicesService, ThreadPool threadPool, ShardStateAction shardStateAction, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver)

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.
protected ReplicationOperation.Replicas	newReplicasProxy()
protected ResyncReplicationResponse	newResponseInstance(StreamInput in)
static ResyncReplicationRequest	performOnPrimary(ResyncReplicationRequest request)
static Translog.Location	performOnReplica(ResyncReplicationRequest request, IndexShard replica)
protected void	shardOperationOnPrimary(ResyncReplicationRequest request, IndexShard primary, ActionListener<TransportReplicationAction.PrimaryResult<ResyncReplicationRequest,ResyncReplicationResponse>> listener)	Called on the primary with a reference to the primary IndexShard to modify.
protected TransportWriteAction.WriteReplicaResult<ResyncReplicationRequest>	shardOperationOnReplica(ResyncReplicationRequest request, IndexShard replica)	Called once per replica with a reference to the replica IndexShard to modify.
void	sync(ResyncReplicationRequest request, Task parentTask, java.lang.String primaryAllocationId, long primaryTerm, ActionListener<ResyncReplicationResponse> listener)

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

locationToSync, syncOperationResultOrThrow

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

acquirePrimaryOperationPermit, acquireReplicaOperationPermit, doExecute, handleOperationRequest, handlePrimaryRequest, handleReplicaRequest, resolveIndex, resolveRequest, retryPrimaryException, transportOptions

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 Detail

TransportResyncReplicationAction

@Inject
public TransportResyncReplicationAction(Settings settings,
                                        TransportService transportService,
                                        ClusterService clusterService,
                                        IndicesService indicesService,
                                        ThreadPool threadPool,
                                        ShardStateAction shardStateAction,
                                        ActionFilters actionFilters,
                                        IndexNameExpressionResolver indexNameExpressionResolver)

Method Detail

newResponseInstance

protected ResyncReplicationResponse newResponseInstance(StreamInput in)
                                                 throws java.io.IOException

Specified by:

newResponseInstance in class TransportReplicationAction<ResyncReplicationRequest,ResyncReplicationRequest,ResyncReplicationResponse>

Throws:

java.io.IOException

newReplicasProxy

protected ReplicationOperation.Replicas newReplicasProxy()

Overrides:

newReplicasProxy in class TransportWriteAction<ResyncReplicationRequest,ResyncReplicationRequest,ResyncReplicationResponse>

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 TransportWriteAction<ResyncReplicationRequest,ResyncReplicationRequest,ResyncReplicationResponse>

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 TransportWriteAction<ResyncReplicationRequest,ResyncReplicationRequest,ResyncReplicationResponse>

shardOperationOnPrimary

protected void shardOperationOnPrimary(ResyncReplicationRequest request,
                                       IndexShard primary,
                                       ActionListener<TransportReplicationAction.PrimaryResult<ResyncReplicationRequest,ResyncReplicationResponse>> listener)

Description copied from class: TransportWriteAction

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

Specified by:

shardOperationOnPrimary in class TransportWriteAction<ResyncReplicationRequest,ResyncReplicationRequest,ResyncReplicationResponse>

Parameters:

request - the request to the primary shard

primary - the primary shard to perform the operation on

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

performOnPrimary

public static ResyncReplicationRequest performOnPrimary(ResyncReplicationRequest request)

shardOperationOnReplica

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

Description copied from class: TransportWriteAction

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

Specified by:

shardOperationOnReplica in class TransportWriteAction<ResyncReplicationRequest,ResyncReplicationRequest,ResyncReplicationResponse>

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

performOnReplica

public static Translog.Location performOnReplica(ResyncReplicationRequest request,
                                                 IndexShard replica)
                                          throws java.lang.Exception

Throws:

java.lang.Exception

sync

public void sync(ResyncReplicationRequest request,
                 Task parentTask,
                 java.lang.String primaryAllocationId,
                 long primaryTerm,
                 ActionListener<ResyncReplicationResponse> listener)

Specified by:

sync in interface PrimaryReplicaSyncer.SyncAction