Package org.elasticsearch.index.seqno
Class RetentionLeaseSyncAction
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<RetentionLeaseSyncAction.Request,RetentionLeaseSyncAction.Request,RetentionLeaseSyncAction.Response>
org.elasticsearch.index.seqno.RetentionLeaseSyncAction
public class RetentionLeaseSyncAction extends TransportWriteAction<RetentionLeaseSyncAction.Request,RetentionLeaseSyncAction.Request,RetentionLeaseSyncAction.Response>
Write action responsible for syncing retention leases to replicas. This action is deliberately a write action so that if a replica misses
a retention lease sync then that shard will be marked as stale.
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
RetentionLeaseSyncAction.Request
static class
RetentionLeaseSyncAction.Response
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 Modifier and Type Field Description static java.lang.String
ACTION_NAME
Fields inherited from class org.elasticsearch.action.support.replication.TransportReplicationAction
clusterService, indicesService, REPLICATION_INITIAL_RETRY_BACKOFF_BOUND, REPLICATION_RETRY_TIMEOUT, shardStateAction, threadPool, transportOptions, transportPrimaryAction, transportReplicaAction, transportService
Fields inherited from class org.elasticsearch.action.support.TransportAction
actionName, logger, taskManager
-
Constructor Summary
Constructors Constructor Description RetentionLeaseSyncAction(Settings settings, TransportService transportService, ClusterService clusterService, IndicesService indicesService, ThreadPool threadPool, ShardStateAction shardStateAction, ActionFilters actionFilters, IndexingPressure indexingPressure)
-
Method Summary
Modifier and Type Method Description protected void
dispatchedShardOperationOnPrimary(RetentionLeaseSyncAction.Request request, IndexShard primary, ActionListener<TransportReplicationAction.PrimaryResult<RetentionLeaseSyncAction.Request,RetentionLeaseSyncAction.Response>> listener)
protected void
dispatchedShardOperationOnReplica(RetentionLeaseSyncAction.Request request, IndexShard replica, ActionListener<TransportReplicationAction.ReplicaResult> listener)
protected void
doExecute(Task parentTask, RetentionLeaseSyncAction.Request request, ActionListener<RetentionLeaseSyncAction.Response> listener)
protected org.apache.logging.log4j.Logger
getLogger()
ClusterBlockLevel
indexBlockLevel()
Index level block to check before request execution.protected RetentionLeaseSyncAction.Response
newResponseInstance(StreamInput in)
Methods inherited from class org.elasticsearch.action.support.replication.TransportWriteAction
checkOperationLimits, checkPrimaryLimits, checkReplicaLimits, globalBlockLevel, locationToSync, newReplicasProxy, primaryOperationSize, replicaOperationSize, shardOperationOnPrimary, shardOperationOnReplica, syncOperationResultOrThrow
Methods inherited from class org.elasticsearch.action.support.replication.TransportReplicationAction
acquirePrimaryOperationPermit, acquireReplicaOperationPermit, adaptResponse, handlePrimaryRequest, handleReplicaRequest, resolveRequest, retryPrimaryException, transportOptions
Methods inherited from class org.elasticsearch.action.support.TransportAction
execute, execute, execute
-
Field Details
-
ACTION_NAME
public static final java.lang.String ACTION_NAME- See Also:
- Constant Field Values
-
-
Constructor Details
-
RetentionLeaseSyncAction
@Inject public RetentionLeaseSyncAction(Settings settings, TransportService transportService, ClusterService clusterService, IndicesService indicesService, ThreadPool threadPool, ShardStateAction shardStateAction, ActionFilters actionFilters, IndexingPressure indexingPressure)
-
-
Method Details
-
getLogger
protected org.apache.logging.log4j.Logger getLogger() -
doExecute
protected void doExecute(Task parentTask, RetentionLeaseSyncAction.Request request, ActionListener<RetentionLeaseSyncAction.Response> listener) -
dispatchedShardOperationOnPrimary
protected void dispatchedShardOperationOnPrimary(RetentionLeaseSyncAction.Request request, IndexShard primary, ActionListener<TransportReplicationAction.PrimaryResult<RetentionLeaseSyncAction.Request,RetentionLeaseSyncAction.Response>> listener) -
dispatchedShardOperationOnReplica
protected void dispatchedShardOperationOnReplica(RetentionLeaseSyncAction.Request request, IndexShard replica, ActionListener<TransportReplicationAction.ReplicaResult> listener) -
indexBlockLevel
Description copied from class:TransportReplicationAction
Index level block to check before request execution. Returning null means that no blocks need to be checked. -
newResponseInstance
protected RetentionLeaseSyncAction.Response newResponseInstance(StreamInput in) throws java.io.IOException- Specified by:
newResponseInstance
in classTransportReplicationAction<RetentionLeaseSyncAction.Request,RetentionLeaseSyncAction.Request,RetentionLeaseSyncAction.Response>
- Throws:
java.io.IOException
-