datacake-cluster 0.1.0

Eventually consistent state replication as a library (consensus, RPC and conflict resolution) for building your own eventually consistent databases.
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
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78

use std::marker::PhantomData;

use datacake_crdt::{HLCTimestamp, Key, OrSWotSet, StateChanges};
use puppet::{derive_message, Message};

use crate::storage::BulkMutationError;
use crate::{Document, PutContext, Storage};

#[derive(Debug, thiserror::Error)]
#[error("Failed to (de)serialize state.")]
pub struct CorruptedState;

pub const NUM_SOURCES: usize = 2;

#[derive(Clone)]
pub struct Set<S> {
    pub source: usize,
    pub doc: Document,
    pub ctx: Option<PutContext>,
    pub _marker: PhantomData<S>,
}
impl<S: Storage> Message for Set<S> {
    type Output = Result<(), S::Error>;
}

#[derive(Clone)]
pub struct MultiSet<S> {
    pub source: usize,
    pub docs: Vec<Document>,
    pub ctx: Option<PutContext>,
    pub _marker: PhantomData<S>,
}
impl<S: Storage> Message for MultiSet<S> {
    type Output = Result<(), BulkMutationError<S::Error>>;
}

#[derive(Clone)]
pub struct Del<S> {
    pub source: usize,
    pub doc_id: Key,
    pub ts: HLCTimestamp,
    pub _marker: PhantomData<S>,
}
impl<S: Storage> Message for Del<S> {
    type Output = Result<(), S::Error>;
}

#[derive(Clone)]
pub struct MultiDel<S> {
    pub source: usize,
    pub key_ts_pairs: StateChanges,
    pub _marker: PhantomData<S>,
}
impl<S: Storage> Message for MultiDel<S> {
    type Output = Result<(), BulkMutationError<S::Error>>;
}

#[derive(Debug, Copy, Clone)]
pub struct Serialize;
derive_message!(Serialize, Result<Vec<u8>, CorruptedState>);

#[derive(Debug, Copy, Clone)]
pub struct LastUpdated;
derive_message!(LastUpdated, HLCTimestamp);

#[derive(Debug, Clone)]
pub struct Diff(pub OrSWotSet<NUM_SOURCES>);
derive_message!(Diff, (StateChanges, StateChanges));

#[derive(Debug, Clone)]
pub struct SymDiff(pub OrSWotSet<NUM_SOURCES>);
derive_message!(SymDiff, (StateChanges, StateChanges));

#[derive(Debug, Copy, Clone)]
pub struct PurgeDeletes<S>(pub PhantomData<S>);
impl<S: Storage> Message for PurgeDeletes<S> {
    type Output = Result<(), S::Error>;
}