Struct VectorClock 

pub struct VectorClock { /* private fields */ }

A vector clock for causal ordering across fleet nodes.

Implementations

impl VectorClock

pub fn new() -> Self

Create a new empty vector clock.

pub fn from_node(node: &str, time: u64) -> Self

Create with a single node’s timestamp.

pub fn increment(&mut self, node: &str) -> u64

Increment a node’s counter (after a local event).

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

Get a node’s counter.

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

Merge with another vector clock (element-wise max). Returns self after merging.

pub fn compare(&self, other: &Self) -> CausalOrder

Compare causal ordering with another clock.

pub fn happened_before_or_equal(&self, other: &Self) -> bool

Is this clock happened-before or equal to other?

pub fn is_concurrent(&self, other: &Self) -> bool

Is this clock concurrent with other?

pub fn node_count(&self) -> usize

Number of nodes in this clock.

pub fn total_time(&self) -> u64

Total logical time (sum of all counters).

pub fn nodes(&self) -> Vec<&String>

All nodes tracked.

pub fn to_json(&self) -> String

Serialize to JSON.

pub fn from_json(s: &str) -> Option<Self>

Deserialize from JSON.

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for VectorClock

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for VectorClock

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

Formats the value using the given formatter.

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 Serialize for VectorClock

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for VectorClock