Enum CrdtValue 

pub enum CrdtValue {
    Set(ORSet<CrdtScalar>),
    SetRemoveWins(ORSet<CrdtScalar, RemoveWins>),
    Seq(RGA<CrdtScalar>),
    Register(MVRegister<CrdtScalar>),
}

A live CRDT held by the interpreter. Wraps the actual logicaffeine_data type, so its convergence behaviour is identical to the compiled tier’s by construction.

Variants

Set(ORSet<CrdtScalar>)

SharedSet of T / SharedSet (AddWins) — observed-remove set, add-wins on a concurrent add/remove of the same element.

SetRemoveWins(ORSet<CrdtScalar, RemoveWins>)

SharedSet (RemoveWins) — observed-remove set, remove-wins on a concurrent add/remove (e.g. an access-revocation / block list).

Seq(RGA<CrdtScalar>)

SharedSequence of T — replicated growable array (RGA). Stable, convergent insertion order.

Register(MVRegister<CrdtScalar>)

Divergent T — multi-value register (MVRegister). Keeps concurrent writes until one is resolved.

Implementations

impl CrdtValue

pub fn new_set(replica: ReplicaId) -> CrdtValue

pub fn new_set_remove_wins(replica: ReplicaId) -> CrdtValue

pub fn new_seq(replica: ReplicaId) -> CrdtValue

pub fn new_register(replica: ReplicaId) -> CrdtValue

pub fn kind(&self) -> &'static str

The CRDT kind, used for type errors and type_name.

pub fn insert(&mut self, value: &RuntimeValue) -> Result<(), String>

Add element to <set> — insert into the observed-remove set.

pub fn remove(&mut self, value: &RuntimeValue) -> Result<(), String>

Remove element from <set> — observed-remove deletion.

pub fn contains(&self, value: &RuntimeValue) -> Result<bool, String>

<set> contains element — observed-remove membership.

pub fn append(&mut self, value: &RuntimeValue) -> Result<(), String>

Append element to <sequence> — RGA append at the end.

pub fn resolve(&mut self, value: &RuntimeValue) -> Result<(), String>

Set <register> to value / Resolve <register> to value — the divergent register takes a value that dominates all concurrent ones.

pub fn len(&self) -> usize

length of <collection> — element count (set cardinality or sequence length).

pub fn is_empty(&self) -> bool

pub fn to_runtime_vec(&self) -> Vec<RuntimeValue>

The elements as runtime values, in convergent order for a sequence and sorted for a set (sets have no intrinsic order — sorting makes the rendering deterministic).

pub fn register_value(&self) -> Option<RuntimeValue>

The resolved value of a register — the single current value, or None while it is empty or still divergent (multiple concurrent values).

pub fn merge(&mut self, other: &CrdtValue) -> Result<(), String>

Merge another CRDT of the SAME kind into this one (the convergent join). Mismatched kinds are a type error rather than a silent no-op.

pub fn version(&self) -> VClock

The current causal version (vector clock) — every update this replica has observed. The δ-CRDT mergeable send remembers the version it last shipped to a peer and ships only the delta SINCE that version, so a large set/sequence syncs its few NEW entries, not its whole state. Idempotent + commutative, so reordering or redelivering deltas still converges.

pub fn delta_since_bytes(&self, since: &VClock) -> Option<Vec<u8>>

Serialize the changes since since as a KIND-TAGGED delta payload — far smaller than the full state when little changed. None if the variant can’t produce a delta (history truncated); the caller falls back to the full-state crdt_to_wire.

pub fn apply_delta_bytes(&mut self, bytes: &[u8]) -> bool

Apply a kind-tagged delta from delta_since_bytes of the SAME kind. Returns false on a kind mismatch or malformed bytes, leaving self unchanged — a foreign / garbage delta never corrupts the CRDT (the network-edge safety the mergeable receive needs).

pub fn render(&self) -> String

Show rendering: a set renders in set notation {…} (matching a plain Set), a sequence as an ordered list […], a register as its resolved value (or, while still divergent, the brace-joined set of concurrent values).

Trait Implementations

impl Clone for CrdtValue

fn clone(&self) -> CrdtValue

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CrdtValue

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

Formats the value using the given formatter.