Enum CrdtOperation 

pub enum CrdtOperation {
    UpdatePosition {
        node_id: NodeId,
        position: Position,
        timestamp: Timestamp,
    },
    UpdateHealth {
        node_id: NodeId,
        status: HealthStatus,
        timestamp: Timestamp,
    },
    IncrementCounter {
        counter_id: u8,
        node_id: NodeId,
        amount: u64,
    },
    UpdateRegister {
        key: String,
        value: Vec<u8>,
        timestamp: Timestamp,
        node_id: NodeId,
    },
}

CRDT operation types for sync

Variants

UpdatePosition

Update a position register

Fields

node_id: NodeId

Node ID that owns this position

position: Position

Position data

timestamp: Timestamp

Timestamp of the update

UpdateHealth

Update health status register

Fields

node_id: NodeId

Node ID that owns this status

status: HealthStatus

Health status data

timestamp: Timestamp

Timestamp of the update

IncrementCounter

Increment a counter

Fields

counter_id: u8

Counter identifier

node_id: NodeId

Node performing the increment

amount: u64

Amount to increment

UpdateRegister

Generic LWW update (key-value)

Fields

key: String

Key for the register

value: Vec<u8>

Value data

timestamp: Timestamp

Timestamp of the update

node_id: NodeId

Node that set the value

Implementations

impl CrdtOperation

pub fn size(&self) -> usize

Get the approximate size in bytes

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

Encode to bytes

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

Decode from bytes

Trait Implementations

impl Clone for CrdtOperation

fn clone(&self) -> CrdtOperation

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CrdtOperation

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

Formats the value using the given formatter.