Struct VectorClock 

pub struct VectorClock { /* private fields */ }

Logical vector clock for causal ordering between workers.

Each entry maps a worker ID to its logical timestamp. Used only when workers have causal dependencies. For most workloads, this is None on DeltaBatch — timestamp alone handles last-write-wins convergence.

Implementations

impl VectorClock

pub fn new() -> VectorClock

pub fn get(&self, worker_id: &str) -> u64

Get the timestamp for a specific worker (0 if absent).

pub fn set(&mut self, worker_id: impl Into<SmolStr>, ts: u64)

Set the timestamp for a specific worker.

pub fn tick(&mut self, worker_id: impl Into<SmolStr>) -> u64

Increment the timestamp for a worker, returning the new value.

pub fn merge(&mut self, other: &VectorClock)

Merge another clock (component-wise maximum).

pub fn happens_before(&self, other: &VectorClock) -> bool

Returns true if every entry in self is <= the corresponding entry in other.

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

Trait Implementations

impl Clone for VectorClock

fn clone(&self) -> VectorClock

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for VectorClock

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

Formats the value using the given formatter.

impl Default for VectorClock

fn default() -> VectorClock

Returns the “default value” for a type.

impl PartialEq for VectorClock

fn eq(&self, other: &VectorClock) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for VectorClock

impl StructuralPartialEq for VectorClock