Struct QuorumCoordinator 

pub struct QuorumCoordinator { /* private fields */ }

Tracks per-replica region bindings and pairs them with the primary’s ack map. PrimaryReplication owns the WAL buffer + ReplicaState list; this coordinator adds the region dimension and the wait-for- quorum logic without duplicating the ack table.

Implementations

impl QuorumCoordinator

pub fn new(primary: Arc<PrimaryReplication>, config: QuorumConfig) -> Self

pub fn bind_replica_region(&self, replica_id: &str, region: &str)

Associate a replica with its region. Called by the primary’s handshake handler when a replica connects — the replica declares its region in the handshake payload.

pub fn unbind_replica(&self, replica_id: &str)

Forget a replica’s region binding on disconnect. Safe to call repeatedly; no-op if the binding doesn’t exist.

pub fn connected_regions(&self) -> HashSet<String>

Which regions currently have at least one connected replica?

pub fn wait_for_quorum(&self, target_lsn: u64) -> Result<(), QuorumError>

Wait until the configured quorum has acked target_lsn.

Returns Ok(()) on successful quorum, Err(QuorumError) on timeout or early-exit validation failures. Async mode returns immediately — the caller already has the primary WAL confirmation.

pub fn has_quorum(&self, target_lsn: u64) -> bool

Fast-check the quorum predicate without waiting. Returns true when the current ack map already satisfies the quorum for target_lsn.

pub fn safe_replay_lsn(&self) -> Option<u64>

Minimum LSN across all connected replicas — the “safe replay” watermark. Any WAL segment whose records are all <= this can be pruned from the primary’s spool without losing any replica’s ability to catch up.

pub fn config(&self) -> &QuorumConfig

Config accessor.