Enum Operation 

pub enum Operation {
    IncrementCounter {
        counter_id: u8,
        node_id: NodeId,
        amount: u64,
        timestamp: u64,
    },
    UpdatePeripheral {
        peripheral: Peripheral,
        timestamp: u64,
    },
    SetEmergency {
        source_node: NodeId,
        timestamp: u64,
        known_peers: Vec<u32>,
    },
    AckEmergency {
        node_id: NodeId,
        emergency_timestamp: u64,
    },
    ClearEmergency {
        emergency_timestamp: u64,
    },
}

A CRDT operation for delta sync

Variants

IncrementCounter

Increment a counter

Fields

counter_id: u8

Counter ID (0 = default mesh counter)

node_id: NodeId

Node that incremented

amount: u64

Amount to increment

timestamp: u64

Timestamp of increment

UpdatePeripheral

Update peripheral state

Fields

peripheral: Peripheral

The peripheral data

timestamp: u64

Timestamp of update

SetEmergency

Set an emergency event

Fields

source_node: NodeId

Source node declaring emergency

timestamp: u64

Timestamp of emergency

known_peers: Vec<u32>

Known peers at time of emergency

AckEmergency

Acknowledge an emergency

Fields

node_id: NodeId

Node sending the ACK

emergency_timestamp: u64

Timestamp of emergency being ACKed

ClearEmergency

Clear an emergency

Fields

emergency_timestamp: u64

Timestamp of emergency being cleared

Implementations

impl Operation

pub fn timestamp(&self) -> u64

Get the timestamp associated with this operation

pub fn key(&self) -> String

Get a unique key for this operation (for deduplication)

pub fn encode(&self) -> Vec<u8>

Encode to bytes

pub fn decode(data: &[u8]) -> Option<(Self, usize)>

Decode from bytes

Trait Implementations

impl Clone for Operation

fn clone(&self) -> Operation

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Operation

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

Formats the value using the given formatter.