Struct AckTracker 

pub struct AckTracker { /* private fields */ }

Available on crate feature sync only.

Acknowledgment tracker

Tracks pending acknowledgments and manages retransmission logic.

Implementations

impl AckTracker

pub fn new() -> Self

Create a new ack tracker with default settings

pub fn with_rto( initial_rto: Duration, min_rto: Duration, max_rto: Duration, backoff_multiplier: u32, max_retransmits: u32, ) -> Self

Create with custom RTO settings

pub fn register_sent(&mut self, version: u64)

Register a sent message that needs acknowledgment

pub fn process_ack(&mut self, acked_version: u64) -> Option<Duration>

Process an incoming acknowledgment

Returns the RTT sample if this ack is for a pending message.

pub fn current_rto(&self) -> Duration

Get current RTO based on RTT estimates

pub fn srtt(&self) -> Option<Duration>

Get the smoothed RTT if available

pub fn rttvar(&self) -> Option<Duration>

Get the RTT variance if available

pub fn needs_retransmit(&self) -> impl Iterator<Item = u64> + '_

Get pending acks that need retransmission

pub fn failed_versions(&self) -> impl Iterator<Item = u64> + '_

Get versions that have exceeded max retransmits

pub fn mark_retransmitted(&mut self, version: u64)

Mark a version as retransmitted

pub fn has_pending(&self) -> bool

Check if there are pending acknowledgments

pub fn pending_count(&self) -> usize

Get number of pending acknowledgments

pub fn highest_acked(&self) -> u64

Get highest acknowledged version

pub fn time_until_retransmit(&self) -> Option<Duration>

Get time until next retransmission is needed

pub fn cancel(&mut self, version: u64)

Cancel a pending ack (e.g., on connection close)

pub fn cancel_all(&mut self)

Cancel all pending acks

pub fn reset(&mut self)

Reset tracker state

Trait Implementations

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.