Struct DeltaReplica 

pub struct DeltaReplica<S: Lattice, D: Lattice = S> {
    pub id: ReplicaId,
    /* private fields */
}

A delta-CRDT replica implementing Algorithm 1

Fields

id: ReplicaId

Replica identifier

Implementations

impl<S: Lattice, D: Lattice> DeltaReplica<S, D>

pub fn new(id: impl Into<ReplicaId>) -> Self

Create a new replica with default buffer size

pub fn with_buffer_size(id: impl Into<ReplicaId>, buffer_size: usize) -> Self

Create a new replica with specified buffer size

pub fn state(&self) -> &S

Get current state (read-only)

pub fn buffer(&self) -> &DeltaBuffer<D>

Get mutable access to buffer

pub fn register_peer(&mut self, peer_id: ReplicaId)

Register a peer for anti-entropy

pub fn current_seq(&self) -> SeqNo

Current sequence number

impl<S: Lattice + Clone> DeltaReplica<S, S>

Delta-CRDT replica where state and delta are the same type

pub fn mutate<F>(&mut self, mutator: F) -> S

where F: FnOnce(&S) -> S,

Apply a delta-mutator: computes delta, applies to state, buffers delta Returns the computed delta

pub fn prepare_sync(&self, peer_id: &str) -> Option<(S, SeqNo)>

Get delta-group to send to a peer

pub fn receive_delta(&mut self, delta: &S)

Receive and apply a delta from a peer (idempotent!)

pub fn process_ack(&mut self, peer_id: &str, seq: SeqNo)

Process an ack from a peer

pub fn full_state(&self) -> &S

Full state (for initial sync or recovery)

pub fn sync_with(&mut self, other: &mut DeltaReplica<S, S>)

Sync with another replica directly (for testing/simulation)

Trait Implementations

impl<S: Clone + Lattice, D: Clone + Lattice> Clone for DeltaReplica<S, D>

fn clone(&self) -> DeltaReplica<S, D>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S: Debug + Lattice, D: Debug + Lattice> Debug for DeltaReplica<S, D>

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

Formats the value using the given formatter.