Struct CommitWaiter 

pub struct CommitWaiter { /* private fields */ }

Implementations

impl CommitWaiter

pub fn new() -> CommitWaiter

pub fn record_replica_ack(&self, replica_id: &str, lsn: u64)

Replica reports it has durably persisted up to lsn. Idempotent: only advances forward. Wakes every waiter so they can recheck their threshold.

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

Best-effort cleanup when a replica disconnects. Removes its durable LSN from the map so it doesn’t artificially inflate ack_n counts. Wakes waiters because the count of replicas at the target may have decreased — they need to re-evaluate against the new reality (some will start failing if their margin was thin).

pub fn snapshot(&self) -> Vec<(String, u64)>

Snapshot of the current durable-LSN map. Useful for observability and tests; doesn’t unblock waiters.

pub fn await_acks( &self, target_lsn: u64, required: u32, timeout: Duration, ) -> AwaitOutcome

Block until at least required replicas have durable LSN >= target_lsn, or timeout expires. required == 0 is a no-op (returns NotRequired instantly).

Uses Condvar::wait_timeout to avoid spinning. On every wake (whether from an ack or a spurious wakeup), we recompute the count and either return or wait again with the remaining budget.

pub fn metrics_snapshot(&self) -> (u64, u64, u64, u64)

Snapshot of outcome counters for /metrics + tests.

Trait Implementations

impl Debug for CommitWaiter

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

Formats the value using the given formatter.

impl Default for CommitWaiter

fn default() -> CommitWaiter

Returns the “default value” for a type.