Struct HlcClock 

pub struct HlcClock {
    physical: AtomicU64,
    logical: AtomicU64,
    node_id: u64,
    max_drift_us: u64,
}

Hybrid Logical Clock for generating causally-ordered timestamps.

Thread-safe implementation using atomics for the state.

Fields

physical: AtomicU64

logical: AtomicU64

node_id: u64

max_drift_us: u64

Implementations

impl HlcClock

pub fn new(node_id: u64) -> HlcClock

Create a new HLC clock with the given node ID.

pub fn with_max_drift(node_id: u64, max_drift_ms: u64) -> HlcClock

Create a new HLC clock with custom max drift.

pub fn node_id(&self) -> u64

Get the node ID.

pub fn now(&self) -> HlcTimestamp

Get current timestamp without advancing the clock.

pub fn tick(&self) -> HlcTimestamp

Generate a new timestamp, advancing the clock.

pub fn update( &self, received: &HlcTimestamp, ) -> Result<HlcTimestamp, RingKernelError>

Update clock on receiving a message with the given timestamp.

Returns the new local timestamp that causally follows the received timestamp.

Trait Implementations

impl Debug for HlcClock

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

Formats the value using the given formatter.