azure_iot_operations_protocol::common::hybrid_logical_clock

Struct HybridLogicalClock

Source
pub struct HybridLogicalClock {
    pub timestamp: SystemTime,
    pub counter: u64,
    pub node_id: String,
}
Expand description

Hybrid Logical Clock (HLC) generating unique timestamps

Fields§

§timestamp: SystemTime

Current timestamp.

§counter: u64

Counter is used to coordinate ordering of events within a distributed system where each device may have slightly different system clock times.

§node_id: String

Unique identifier for this node.

Implementations§

Source§

impl HybridLogicalClock

Source

pub fn new() -> Self

Creates a new HybridLogicalClock with the current timestamp, a counter of 0, and a unique identifier

Source

pub fn update( &mut self, other: &HybridLogicalClock, max_clock_drift: Duration, ) -> Result<(), HLCError>

Updates the HybridLogicalClock based on another HybridLogicalClock. Self will be set to the latest timestamp between itself, other, and the current time, and its counter will also be updated accordingly.

Note: Update performed against another HybridLogicalClock with the same node_id is a no-op, and will not result in an error.

§Errors

HLCError of kind OverflowWarning if the HybridLogicalClock’s counter would be set to a value that would overflow beyond u64::MAX

HLCError of kind ClockDrift if the latest HybridLogicalClock (of Self or other)’s timestamp is too far in the future (determined by max_clock_drift) compared to SystemTime::now()

Source

pub fn update_now(&mut self, max_clock_drift: Duration) -> Result<(), HLCError>

Updates the HybridLogicalClock based on the current time

§Errors

HLCError of kind OverflowWarning if the HybridLogicalClock’s counter would be set to a value that would overflow beyond u64::MAX

HLCError of kind ClockDrift if the HybridLogicalClock timestamp is too far in the future (determined by max_clock_drift) compared to SystemTime::now() compared to SystemTime::now()

Trait Implementations§

Source§

impl Clone for HybridLogicalClock

Source§

fn clone(&self) -> HybridLogicalClock

Returns a copy of the value. Read more
1.0.0 · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Debug for HybridLogicalClock

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Default for HybridLogicalClock

Source§

fn default() -> Self

Returns the “default value” for a type. Read more
Source§

impl Display for HybridLogicalClock

Source§

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

Formats the value using the given formatter. Read more
Source§

impl FromStr for HybridLogicalClock

Source§

type Err = ParseHLCError

The associated error which can be returned from parsing.
Source§

fn from_str(s: &str) -> Result<Self, ParseHLCError>

Parses a string s to return a value of this type. Read more
Source§

impl PartialEq for HybridLogicalClock

Source§

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

Tests for self and other values to be equal, and is used by ==.
1.0.0 · Source§

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

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

impl StructuralPartialEq for HybridLogicalClock

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dst: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dst. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T> ToString for T
where T: Display + ?Sized,

Source§

fn to_string(&self) -> String

Converts the given value to a String. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

§

fn vzip(self) -> V