Struct ReplicationOptions 

pub struct ReplicationOptions {
    pub batch_size: u64,
    pub batches_limit: u64,
    pub filter: Option<ReplicationFilter>,
    pub live: bool,
    pub retry: bool,
    pub poll_interval: Duration,
    pub back_off_function: Option<Box<dyn Fn(u32) -> Duration + Send + Sync>>,
    pub since: Option<Seq>,
    pub checkpoint: bool,
}

Replication configuration.

Fields

batch_size: u64

Number of documents to process per batch.

batches_limit: u64

Maximum number of batches to buffer.

filter: Option<ReplicationFilter>

Optional filter for selective replication.

live: bool

Enable continuous/live replication.

retry: bool

Automatically retry on transient errors.

poll_interval: Duration

Polling interval for live replication (default: 500ms).

back_off_function: Option<Box<dyn Fn(u32) -> Duration + Send + Sync>>

Backoff function for retry: takes attempt number, returns delay.

since: Option<Seq>

Override the starting sequence (skip checkpoint lookup).

checkpoint: bool

Whether to save/read checkpoints (default: true). Set to false to always replicate from scratch.

Trait Implementations

impl Default for ReplicationOptions

fn default() -> Self

Returns the “default value” for a type.