Struct hybrid_clocks::OffsetLimiter

pub struct OffsetLimiter<S: ClockSource> { /* fields omitted */ }

A wrapper around Clock that will refuse updates outside of our tolerance.

Implementations

impl<S: ClockSource> OffsetLimiter<S>

pub fn new(clock: Clock<S>, max_offset: S::Delta) -> Self

pub fn observe(&mut self, msg: &Timestamp<S::Time>) -> Result<()>

Accepts a timestamp from an incoming message, and updates the clock so that further calls to now will always return a timestamp that happens-after either locally generated timestamps or that of the input message. Returns an Error iff the delta from our local lock to the observed timestamp is greater than our configured limit.

pub fn now(&mut self) -> Result<Timestamp<S::Time>>

Creates a unique monotonic timestamp suitable for annotating messages we send.

pub fn into_inner(self) -> Clock<S>

Extract the inner Clock

pub fn inner(&self) -> &Clock<S>

Get a reference to the inner Clock

pub fn inner_mut(&mut self) -> &mut Clock<S>

Get a mutable reference to the inner Clock

Trait Implementations

impl<S: Clone + ClockSource> Clone for OffsetLimiter<S> where
    S::Delta: Clone, 

fn clone(&self) -> OffsetLimiter<S>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<S: Debug + ClockSource> Debug for OffsetLimiter<S> where
    S::Delta: Debug, 

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

Formats the value using the given formatter.