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,
    pub replica_class: ReplicaClass,
    pub cascade_from: Option<CascadeUpstream>,
}

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.

replica_class: ReplicaClass

Streaming class (issue #838). A ReplicaClass::Voting node is on the durability/election path and always streams directly from the primary; a ReplicaClass::AsyncReadReplica may cascade from an intermediate. Defaults to Voting — a node only cascades when explicitly declared a read-replica.

cascade_from: Option<CascadeUpstream>

Optional intermediate replica to cascade from (issue #838). Honoured only for an async read-replica; a voting member refuses it and streams directly from the primary. See ReplicationConfig::resolved_upstream.

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

pub fn with_replica_class(self, class: ReplicaClass) -> ReplicationConfig

Set the streaming class explicitly (issue #838).

pub fn cascading_from( self, node_id: impl Into<String>, addr: impl Into<String>, ) -> ReplicationConfig

Declare this node an async read-replica that cascades from intermediate (issue #838). Sets ReplicaClass::AsyncReadReplica and the cascade source together — the only combination that actually streams from an intermediate. A node left at the default Voting class ignores any cascade source and streams directly from the primary.

pub fn resolved_upstream( &self, self_node_id: &str, ) -> (UpstreamChoice, Option<CascadeRefusal>)

Resolve where this node should open its WAL stream, applying the cascade policy (issue #838). A voting member always resolves to the primary even when a cascade source is configured; the returned CascadeRefusal explains any fallback so it is observable rather than silent. self_node_id guards against a node cascading from its own slot.

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.