ossa-crdt 0.0.1

CRDTs for the Ossa Protocol.
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
31
32
33
34
35
36
37
38

// #![feature(non_lifetime_binders)]

pub mod map;
pub mod register;
pub mod set;
pub mod text;
pub mod time;

use crate::time::CausalState;

// // JP: What should this be called? LogicalOp? MetaOp?
// pub struct AnnotatedOp<M:OpMetadata, Op> {
//     metadata: M,
//     operation: Op,
// }
//
// pub trait OpMetadata {
//     type Time;
//
//     /// Logical time, serving as a unique identifier for this operation.
//     fn time(&self) -> Self::Time;
// }

pub trait CRDT {
    type Op; // <Time>; // Required due to lack of higher kinded types.
    type Time; // TODO: Delete this??

    // TODO: enabled...

    // Mut or return Self?
    // fn apply<'a>(&'a mut self, op: &'a AnnotatedOp<M,Self::Op>); // -> &'a Self;

    // Preconditions:
    // - All `logical_time`s of applied operations must be unique in all subsequent calls to `apply`.
    fn apply<CS: CausalState<Time = Self::Time>>(self, causal_state: &CS, op: Self::Op) -> Self;

    // lawCommutativity :: concurrent t1 t2 => x.apply(t1, op1).apply(t2, op2) == x.apply(t2, op2).apply(t1, op1)
}