Struct ReplicationConfig 

pub struct ReplicationConfig {
    pub role: ReplicationRole,
    pub term: u64,
    pub poll_interval_ms: u64,
    pub max_batch_size: usize,
    pub region: String,
    pub quorum: QuorumConfig,
    pub slot_retention_max_lag_lsn: u64,
    pub slot_idle_timeout_ms: u64,
}

Configuration for replication.

Fields

role: ReplicationRole

term: u64

Current replication term/epoch stamped into WAL-derived records.

poll_interval_ms: u64

How often replica polls for new WAL records (milliseconds).

max_batch_size: usize

Maximum batch size for WAL record transfer.

region: String

Region identifier for this instance (Phase 2.6 multi-region).

Used by the quorum coordinator to spread write acks across fault domains: QuorumConfig::required_regions forces a commit to wait until at least one replica in each listed region has acked. Defaults to "local" for single-region deployments.

quorum: QuorumConfig

Quorum configuration (Phase 2.6 multi-region).

slot_retention_max_lag_lsn: u64

Maximum LSN lag a replication slot may pin before the primary invalidates it and allows WAL pruning to continue.

slot_idle_timeout_ms: u64

Maximum wall-clock idle age for a slot before invalidation.

Implementations

impl ReplicationConfig

pub fn standalone() -> ReplicationConfig

pub fn primary() -> ReplicationConfig

pub fn replica(primary_addr: impl Into<String>) -> ReplicationConfig

pub fn with_quorum(self, quorum: QuorumConfig) -> ReplicationConfig

Attach a quorum configuration (fluent setter).

pub fn with_region(self, region: impl Into<String>) -> ReplicationConfig

Set the region identifier (fluent setter).

pub fn with_term(self, term: u64) -> ReplicationConfig

Set the replication term stamped into newly produced records.

pub fn with_slot_retention_max_lag_lsn( self, max_lag_lsn: u64, ) -> ReplicationConfig

pub fn with_slot_idle_timeout_ms(self, timeout_ms: u64) -> ReplicationConfig

Trait Implementations

impl Clone for ReplicationConfig

fn clone(&self) -> ReplicationConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ReplicationConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.