Struct AckTracker 

pub struct AckTracker { /* private fields */ }

Tracks acknowledgments from peers for garbage collection

Implementations

impl AckTracker

pub fn new() -> Self

pub fn register_peer(&mut self, peer_id: ReplicaId)

Register a peer (initializes ack to 0)

pub fn update_ack(&mut self, peer_id: &str, seq: SeqNo)

Update the ack for a peer

pub fn get_ack(&self, peer_id: &str) -> SeqNo

Get the ack for a peer

pub fn min_acked(&self) -> SeqNo

Get minimum acked sequence across all peers (safe to GC before this)

pub fn peers(&self) -> impl Iterator<Item = &ReplicaId>

Get all registered peers

Trait Implementations

impl Clone for AckTracker

fn clone(&self) -> AckTracker

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AckTracker

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

Formats the value using the given formatter.

impl Default for AckTracker

fn default() -> Self

Returns the “default value” for a type.