Struct AckTracker 

pub struct AckTracker { /* private fields */ }

Collects remote acks against a deadline. Pure logic — no I/O.

Implementations

impl AckTracker

pub fn new(policy: QuorumPolicy, now: Instant) -> Self

Create a tracker for one quorum-write attempt. now is injected for deterministic tests.

pub fn record_local(&mut self)

Record the local commit. Call once the originating node has durably persisted the memory.

pub fn record_peer_ack(&mut self, peer_id: impl Into<String>)

Record a peer ack. peer_id is the caller’s opaque identifier (typically the peer’s mTLS fingerprint or agent id). Duplicate peer_id values are deduplicated.

pub fn record_id_drift(&mut self, peer_id: impl Into<String>)

Record that a peer returned success but with a memory id that differs from the local commit id. Does NOT count toward the quorum and surfaces in metrics.

pub fn is_quorum_met(&self, now: Instant) -> bool

True when the quorum is met: local commit + at least W-1 unique peer acks, and the deadline has not elapsed at now.

pub fn finalise(&self, now: Instant) -> Result<usize, QuorumError>

Finalise the attempt. Returns Ok(count_of_distinct_acks) if quorum met, else Err(QuorumError::QuorumNotMet{…}).

Errors

Returns QuorumError::QuorumNotMet if the deadline elapsed before W acks arrived.

pub fn id_drift_count(&self) -> usize

Count of peers that reported divergent memory ids for this write. Exposed for metrics + debugging.

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

H9 (v0.7.0 round-2) — opaque view onto the set of peer ids that have positively acknowledged this quorum write. Exposed so broadcast_store_quorum (and its delete/archive siblings) can compute missing = configured_peers - acked_peers and surface that set in a tracing::warn! when quorum is met but some peers did not ack — operators need to see the gap in logs before a follow-up sync cycle catches the peer up.

Trait Implementations

impl Debug for AckTracker

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

Formats the value using the given formatter.