Struct QuorumTracker 

pub struct QuorumTracker { /* private fields */ }

Tracks pending operations waiting for quorum acknowledgment.

Supports dual-config quorum: during reconfiguration, an operation must be acknowledged by write quorum from BOTH current and previous configurations. A replica present in both configs counts toward both quorums with a single ACK.

Implementations

impl QuorumTracker

pub fn new() -> Self

pub fn committed_lsn(&self) -> Lsn

pub fn set_catch_up_configuration( &mut self, current_members: HashSet<ReplicaId>, current_write_quorum: u32, previous_members: HashSet<ReplicaId>, previous_write_quorum: u32, must_catch_up_ids: HashSet<ReplicaId>, member_progress: HashMap<ReplicaId, Lsn>, )

Update to dual-config mode (during reconfiguration). Seeds replica_acked_lsn for must_catch_up replicas from their reported current_progress (the operator knows each replica’s LSN).

pub fn set_current_configuration( &mut self, current_members: HashSet<ReplicaId>, current_write_quorum: u32, )

Update to single-config mode (reconfiguration complete).

pub fn register( &mut self, lsn: Lsn, primary_id: ReplicaId, reply: Sender<Result<Lsn>>, )

Register a new pending operation. The primary’s own ACK is counted immediately (primary_id).

pub fn ack(&mut self, lsn: Lsn, replica_id: ReplicaId)

Record an ACK from a secondary. If this causes quorum to be met, the operation is committed and the reply is sent.

pub fn fail_all(&mut self, error: KubericError)

Fail all pending operations (e.g., on role change or close).

pub fn pending_count(&self) -> usize

Number of pending (uncommitted) operations.

pub fn wait_for_catch_up( &mut self, mode: ReplicaSetQuorumMode, reply: Sender<Result<()>>, )

Register a waiter that will be notified when catch-up is complete.

• All mode: all pending ops committed (quorum met for each).
• Write mode: all pending ops committed AND every must_catch_up replica has individually ACKed all ops.

If already caught up, replies immediately.

Trait Implementations

impl Default for QuorumTracker

fn default() -> Self

Returns the “default value” for a type.