Struct MVRegister 

pub struct MVRegister<T: Clone + Ord> { /* private fields */ }

A multi-value register (MV-Register).

Unlike LWW-Register, this preserves all concurrently written values. When concurrent writes occur, all values are kept until a subsequent write supersedes them. This is useful when you want to detect conflicts rather than silently resolving them.

Example

use crdt_kit::prelude::*;

let mut r1 = MVRegister::new(1);
r1.set("alice");

let mut r2 = MVRegister::new(2);
r2.set("bob");

r1.merge(&r2);
// Both values are preserved as concurrent writes
let values = r1.values();
assert!(values.contains(&&"alice"));
assert!(values.contains(&&"bob"));

Implementations

impl<T: Clone + Ord> MVRegister<T>

pub fn new(actor: NodeId) -> Self

Create a new empty MV-Register for the given node.

pub fn set(&mut self, value: T)

Set a new value, superseding all current values.

pub fn values(&self) -> Vec<&T>

Get all current values.

Returns a single value during normal operation, or multiple values when concurrent writes have been merged without a subsequent write.

pub fn is_conflicted(&self) -> bool

Returns true if there are concurrent (conflicting) values.

pub fn actor(&self) -> NodeId

Get this replica’s node ID.

Trait Implementations

impl<T: Clone + Clone + Ord> Clone for MVRegister<T>

fn clone(&self) -> MVRegister<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Clone + Ord> Crdt for MVRegister<T>

fn merge(&mut self, other: &Self)

Merge another replica’s state into this one.

impl<T: Debug + Clone + Ord> Debug for MVRegister<T>

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

Formats the value using the given formatter.

impl<T: Clone + Ord> DeltaCrdt for MVRegister<T>

type Delta = MVRegisterDelta<T>

The type of delta produced by this CRDT.

fn delta(&self, other: &Self) -> MVRegisterDelta<T>

Generate a delta containing changes in self that other does not have.

fn apply_delta(&mut self, delta: &MVRegisterDelta<T>)

Apply a delta to this replica’s state.

impl<T: PartialEq + Clone + Ord> PartialEq for MVRegister<T>

fn eq(&self, other: &MVRegister<T>) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<T: Clone + Ord> Versioned for MVRegister<T>

const CURRENT_VERSION: u8 = 1

Current schema version for this CRDT type’s serialization format.

const CRDT_TYPE: CrdtType = CrdtType::MVRegister

The CRDT type identifier for the envelope.

impl<T: Eq + Clone + Ord> Eq for MVRegister<T>

impl<T: Clone + Ord> StructuralPartialEq for MVRegister<T>