Struct VectorClock 

pub struct VectorClock { /* private fields */ }

Vector clock for tracking causality in distributed systems Each instance maintains its own logical clock version

Implementations

impl VectorClock

pub fn new() -> VectorClock

Create a new empty vector clock

pub fn from_json(json: &str) -> Result<VectorClock, Error>

Create a vector clock from a JSON string

pub fn to_json(&self) -> Result<String, Error>

Serialize to JSON string for storage

pub fn get(&self, instance_id: &str) -> i64

Get the version for a specific instance (0 if not present)

pub fn set(&mut self, instance_id: String, version: i64)

Set the version for a specific instance

pub fn increment(&mut self, instance_id: &str) -> i64

Increment the version for the given instance

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

Merge another vector clock, taking the maximum version for each instance This is used when receiving updates from other instances

pub fn compare(&self, other: &VectorClock) -> ClockOrder

Compare this clock with another to determine causality relationship Returns:

• Before: self happened-before other (self is older)
• After: other happened-before self (self is newer)
• Concurrent: neither happened-before the other (conflict)
• Equal: clocks are identical

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

Check if this clock happened-before another (causally precedes)

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

Check if this clock is concurrent with another (conflict)

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

Check if this clock is equal to another

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

Get all instance IDs tracked by this clock

pub fn instance_count(&self) -> usize

Get the number of instances tracked

pub fn is_empty(&self) -> bool

Check if this clock is empty (no versions tracked)

pub fn clear(&mut self)

Clear all versions

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<'de> Deserialize<'de> for VectorClock

fn deserialize<__D>( __deserializer: __D, ) -> Result<VectorClock, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for VectorClock

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

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 as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for VectorClock

impl StructuralPartialEq for VectorClock