Skip to main content

DeltaCrdt

atomr_distributed_data

Trait DeltaCrdt 

Source 
pub trait DeltaCrdt: CrdtMerge {
    type Delta: Clone + Send + 'static;

    // Required methods
    fn take_delta(&mut self) -> Option<Self::Delta>;
    fn merge_delta(&mut self, delta: &Self::Delta);
}
Expand description

Optional delta-CRDT layer: emit a small “delta” describing the last local change and merge incoming deltas into the full state.

Phase 8.C of docs/full-port-plan.md. CRDTs that implement DeltaCrdt participate in delta-gossip — the Replicator ships Self::Delta to peers instead of the full state, dramatically reducing wire traffic for hot keys.

CRDTs whose state is small (counters, flags) can implement this trivially with Delta = Self. Sets / maps emit a sub-state containing only the keys / tags that changed.

Required Associated Types§

Source

type Delta: Clone + Send + 'static

Per-CRDT delta type — typically Self for small CRDTs, a sub-state for set / map shapes.

Required Methods§

Source

fn take_delta(&mut self) -> Option<Self::Delta>

Take and clear the accumulated local delta. Returns None if no local change has happened since the last call.

Source

fn merge_delta(&mut self, delta: &Self::Delta)

Merge an incoming delta into local state.

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§