org.elasticsearch.action.resync

Class TransportResyncReplicationAction

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

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.OperationTransportHandler, TransportReplicationAction.PrimaryOperationTransportHandler, TransportReplicationAction.PrimaryResult<ReplicaRequest extends ReplicationRequest<ReplicaRequest>,Response extends ReplicationResponse>, TransportReplicationAction.ReplicaOperationTransportHandler, TransportReplicationAction.ReplicaResponse, TransportReplicationAction.ReplicaResult, TransportReplicationAction.ReplicasProxy, TransportReplicationAction.RetryOnReplicaException

Field Summary

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

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

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

actionName, indexNameExpressionResolver, taskManager, threadPool

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

deprecationLogger, logger, settings

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected ReplicationOperation.Replicas	newReplicasProxy(long primaryTerm)
protected ResyncReplicationResponse	newResponseInstance()
static ResyncReplicationRequest	performOnPrimary(ResyncReplicationRequest request, IndexShard primary)
static Translog.Location	performOnReplica(ResyncReplicationRequest request, IndexShard replica)
protected void	registerRequestHandlers(java.lang.String actionName, TransportService transportService, java.util.function.Supplier<ResyncReplicationRequest> request, java.util.function.Supplier<ResyncReplicationRequest> replicaRequest, java.lang.String executor)
protected void	sendReplicaRequest(TransportReplicationAction.ConcreteReplicaRequest<ResyncReplicationRequest> replicaRequest, DiscoveryNode node, ActionListener<ReplicationOperation.ReplicaResponse> listener) Sends the specified replica request to the specified node.
protected TransportWriteAction.WritePrimaryResult<ResyncReplicationRequest,ResyncReplicationResponse>	shardOperationOnPrimary(ResyncReplicationRequest request, IndexShard primary) Called on the primary with a reference to the primary IndexShard to modify.
protected TransportWriteAction.WriteReplicaResult	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

globalBlockLevel, indexBlockLevel, locationToSync, syncOperationResultOrThrow

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

doExecute, doExecute, getIndexShard, resolveIndex, resolveRequest, retryPrimaryException, transportOptions

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

execute, execute, execute, execute

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

logDeprecatedSetting, logRemovedSetting, nodeName

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

registerRequestHandlers

protected void registerRequestHandlers(java.lang.String actionName,
                                       TransportService transportService,
                                       java.util.function.Supplier<ResyncReplicationRequest> request,
                                       java.util.function.Supplier<ResyncReplicationRequest> replicaRequest,
                                       java.lang.String executor)

Overrides:

registerRequestHandlers in class TransportReplicationAction<ResyncReplicationRequest,ResyncReplicationRequest,ResyncReplicationResponse>

newResponseInstance

protected ResyncReplicationResponse newResponseInstance()

Specified by:

newResponseInstance in class TransportReplicationAction<ResyncReplicationRequest,ResyncReplicationRequest,ResyncReplicationResponse>

newReplicasProxy

protected ReplicationOperation.Replicas newReplicasProxy(long primaryTerm)

Overrides:

newReplicasProxy in class TransportWriteAction<ResyncReplicationRequest,ResyncReplicationRequest,ResyncReplicationResponse>

sendReplicaRequest

protected void sendReplicaRequest(TransportReplicationAction.ConcreteReplicaRequest<ResyncReplicationRequest> replicaRequest,
                                  DiscoveryNode node,
                                  ActionListener<ReplicationOperation.ReplicaResponse> listener)

Description copied from class: TransportReplicationAction

Sends the specified replica request to the specified node.

Overrides:

sendReplicaRequest in class TransportReplicationAction<ResyncReplicationRequest,ResyncReplicationRequest,ResyncReplicationResponse>

Parameters:

replicaRequest - the replica request

node - the node to send the request to

listener - callback for handling the response or failure

shardOperationOnPrimary

protected TransportWriteAction.WritePrimaryResult<ResyncReplicationRequest,ResyncReplicationResponse> shardOperationOnPrimary(ResyncReplicationRequest request,
                                                                                                                              IndexShard primary)
                                                                                                                       throws java.lang.Exception

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

Returns:

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

Throws:

java.lang.Exception

performOnPrimary

public static ResyncReplicationRequest performOnPrimary(ResyncReplicationRequest request,
                                                        IndexShard primary)

shardOperationOnReplica

protected TransportWriteAction.WriteReplicaResult 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