Trait crdts::CvRDT

pub trait CvRDT {
    type Validation: Error;
    fn validate_merge(&self, other: &Self) -> Result<(), Self::Validation>;
    fn merge(&mut self, other: Self);
}

State based CRDT’s replicate by transmitting the entire CRDT state.

Associated Types

type Validation: Error

The validation error returned by validate_merge.

Loading content...

Required methods

fn validate_merge(&self, other: &Self) -> Result<(), Self::Validation>

Some CRDT’s have stricter requirements on how they must be used. To avoid violating these requirements, CRDT’s provide an interface to optionally validate merge compatibility before attempting to merge.

An Ok(()) response signals that the merge is safe to proceed. Otherwise a structured error is returned to help you determine what is wrong with the merge.

fn merge(&mut self, other: Self)

Merge the given CRDT into the current CRDT.

Loading content...

Implementors

impl<A: Ord + Clone + Debug> CvRDT for GCounter<A>

type Validation = Infallible

fn validate_merge(&self, _other: &Self) -> Result<(), Self::Validation>

fn merge(&mut self, other: Self)

impl<A: Ord + Clone + Debug> CvRDT for PNCounter<A>

type Validation = <GCounter<A> as CvRDT>::Validation

fn validate_merge(&self, other: &Self) -> Result<(), Self::Validation>

fn merge(&mut self, other: Self)

impl<A: Ord + Clone + Debug> CvRDT for VClock<A>

type Validation = Infallible

fn validate_merge(&self, _other: &Self) -> Result<(), Self::Validation>

fn merge(&mut self, other: Self)

impl<K: Ord + Clone + Debug, V: Val<A> + CvRDT + Debug, A: Ord + Hash + Clone + Debug> CvRDT for Map<K, V, A>

type Validation = CvRDTValidation<K, V, A>

fn validate_merge(&self, other: &Self) -> Result<(), Self::Validation>

fn merge(&mut self, other: Self)

impl<M: Hash + Eq + Clone + Debug, A: Ord + Hash + Clone + Debug> CvRDT for Orswot<M, A>

type Validation = Validation<M, A>

fn validate_merge(&self, other: &Self) -> Result<(), Self::Validation>

fn merge(&mut self, other: Self)

Merge combines another Orswot with this one.

impl<T: Ord> CvRDT for GList<T>

type Validation = Infallible

fn validate_merge(&self, _: &Self) -> Result<(), Self::Validation>

fn merge(&mut self, other: Self)

impl<T: Ord> CvRDT for GSet<T>

type Validation = Infallible

fn validate_merge(&self, _other: &Self) -> Result<(), Self::Validation>

fn merge(&mut self, other: Self)

Merges another GSet into this one.

Examples

use crdts::{GSet, CvRDT, CmRDT};
let (mut a, mut b) = (GSet::new(), GSet::new());
a.insert(1);
b.insert(2);
a.merge(b);
assert!(a.contains(&1));
assert!(a.contains(&2));

impl<T: Sha3Hash> CvRDT for MerkleReg<T>

type Validation = Infallible

fn validate_merge(&self, _: &Self) -> Result<(), Self::Validation>

fn merge(&mut self, other: Self)

impl<V, A: Ord> CvRDT for MVReg<V, A>

type Validation = Infallible

fn validate_merge(&self, _other: &Self) -> Result<(), Self::Validation>

fn merge(&mut self, other: Self)

impl<V: PartialEq, M: Ord> CvRDT for LWWReg<V, M>

type Validation = Validation

fn validate_merge(&self, other: &Self) -> Result<(), Self::Validation>

Validates whether a merge is safe to perfom

Returns an error if the marker is identical but the contained element is different.

use crdts::{lwwreg, LWWReg, CvRDT};
let mut l1 = LWWReg { val: 1, marker: 2 };
let l2 = LWWReg { val: 3, marker: 2 };
// errors!
assert_eq!(l1.validate_merge(&l2), Err(lwwreg::Validation::ConflictingMarker));

fn merge(&mut self, _: Self)

Combines two LWWReg instances according to the marker that tracks causality.

Loading content...