Struct HlcClock 

pub struct HlcClock { /* private fields */ }

A thread-safe Hybrid Logical Clock.

Create one per process and share it across threads via Arc. Every call to now produces a timestamp strictly greater than the last, and every call to recv advances the clock past an incoming remote timestamp — guaranteeing that your local clock always reflects what it has “seen”.

Implementations

impl HlcClock

pub fn new() -> Self

Create a new clock with the default maximum drift (500 ms).

pub fn with_max_drift(max_drift: Duration) -> Self

Create a new clock with a custom maximum drift.

Received timestamps whose physical component is more than max_drift ahead of the local wall clock will be rejected with HlcError::FutureDrift.

pub fn now(&self) -> Result<HlcTimestamp, HlcError>

Generate a new timestamp for a local event or an outgoing message.

The returned timestamp is strictly greater than every timestamp previously produced by this clock instance.

pub fn recv(&self, msg: HlcTimestamp) -> Result<HlcTimestamp, HlcError>

Advance the clock upon receiving a message stamped with msg.

Returns the updated local timestamp. Attach this to any reply, or use it as the lower-bound for a consistent snapshot read.

Errors

Returns HlcError::FutureDrift if msg.physical is more than max_drift ahead of the local wall clock.

pub fn last(&self) -> HlcTimestamp

Return the last recorded timestamp without advancing the clock.

Trait Implementations

impl Debug for HlcClock

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

Formats the value using the given formatter.

impl Default for HlcClock

fn default() -> Self

Returns the “default value” for a type.