Class ReplicationRequest<Request extends ReplicationRequest<Request>>

All Implemented Interfaces:
IndicesRequest, Writeable, RefCounted, TaskAwareRequest
Direct Known Subclasses:
BasicReplicationRequest, GlobalCheckpointSyncAction.Request, ReplicatedWriteRequest, RetentionLeaseBackgroundSyncAction.Request, ShardFlushRequest, ShardRefreshReplicaRequest, TransportVerifyShardBeforeCloseAction.ShardRequest, TransportVerifyShardIndexBlockAction.ShardRequest

public abstract class ReplicationRequest<Request extends ReplicationRequest<Request>> extends LegacyActionRequest implements IndicesRequest
Requests that are run on a particular replica, first on the primary and then on the replicas like IndexRequest or TransportShardRefreshAction.
  • Field Details

    • DEFAULT_TIMEOUT

      public static final TimeValue DEFAULT_TIMEOUT
    • shardId

      protected final ShardId shardId
      Target shard the request should execute on. In case of index and delete requests, shard id gets resolved by the transport action before performing request operation and at request creation time for shard-level bulk, refresh and flush requests.
    • timeout

      protected TimeValue timeout
    • index

      protected String index
    • waitForActiveShards

      protected ActiveShardCount waitForActiveShards
      The number of shard copies that must be active before proceeding with the replication action.
  • Constructor Details

  • Method Details