Struct SeqClock

pub(crate) struct SeqClock {
    origin: Instant,
    sent_ns: Mutex<HashMap<u64, u64>>,
}

Wall origin plus per-sequence offsets in nanoseconds.

Fields

origin: Instant

sent_ns: Mutex<HashMap<u64, u64>>

Implementations

impl SeqClock

pub(crate) fn new() -> Self

pub(crate) fn stamp(&self, seq: u64) -> u64

Records seq as sent now. Returns the offset used.

pub(crate) fn latency_ns(&self, seq: u64) -> Option<u64>

Nanoseconds from stamp to now, if seq was recorded.

pub(crate) fn sent_ns(&self, seq: u64) -> Option<u64>

Offset of seq, if recorded.