dson 0.3.0

A delta-state CRDT implementation
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

// (c) Copyright 2025 Helsing GmbH. All rights reserved.
use crate::{
    CausalContext, CausalDotStore, Identifier, MvReg,
    crdts::{
        mvreg::MvRegValue,
        snapshot::{SingleValueError, ToValue},
    },
};

/// Returns the values of this register without collapsing conflicts.
pub fn values(m: &MvReg) -> impl ExactSizeIterator<Item = &MvRegValue> {
    m.values().into_iter()
}

/// Returns the value of this register assuming (and asserting) no conflicts on element values.
pub fn value(m: &MvReg) -> Result<&MvRegValue, Box<SingleValueError<MvRegValue>>> {
    m.value()
}

/// Writes a value to the register.
pub fn write(
    v: MvRegValue,
) -> impl FnMut(&MvReg, &CausalContext, Identifier) -> CausalDotStore<MvReg> {
    move |m, cc, id| m.write(v.clone(), cc, id)
}

/// Clears the register.
pub fn clear() -> impl Fn(&MvReg, &CausalContext, Identifier) -> CausalDotStore<MvReg> {
    move |m, _cc, _id| m.clear()
}