Struct Clock

pub struct Clock {
    lamport_clock: i64,
    vector_clock: HashMap<String, i64>,
}

Implements logical clocks for distributed synchronization

The Clock struct maintains both a Lamport clock for total ordering and a vector clock for causal ordering of events across the distributed system.

Fields

lamport_clock: i64

Lamport clock value for total ordering of events

vector_clock: HashMap<String, i64>

Vector clock mapping site IDs to their clock values

Site_id -> clock value

Implementations

impl Clock

pub fn new() -> Self

Creates a new Clock instance with initialized clocks

pub fn from_parts( lamport_clock: i64, vector_clock: HashMap<String, i64>, ) -> Self

fn increment_lamport(&mut self)

Increments the Lamport clock and returns the new value

fn increment_vector(&mut self, site_id: &str)

Increments the vector clock for a specific site and returns the new value

pub fn get_lamport(&self) -> &i64

Returns a reference to the Lamport clock value

pub fn get_vector_clock_map(&self) -> &HashMap<String, i64>

Returns a reference to the vector clock

pub fn get_vector_clock_values(&self) -> Vec<i64>

Returns the vector clock as a list of values

fn update_vector(&mut self, received_vc: &HashMap<String, i64>)

Updates the vector clock with received values, taking the maximum of local and received values

fn update_lamport(&mut self, received_lc: &i64)

Updates the lamport clock with received value, taking the maximum of local and received values

pub fn update_clock( &mut self, local_site_id: &str, received_clock: Option<&Self>, )

Update the current clock value with an optional clock

Local lamport clock is incremented

Element of local vector clock is incremented

Then we call update methods to take the maximum of the received clocks if any

Trait Implementations

impl Clone for Clock

fn clone(&self) -> Clock

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Clock

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Clock

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Clock

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

where __S: Serializer,

Serialize this value into the given Serde serializer.