cmrdts 0.3.0

A collection of Commutative Replicated Data Types (CmRDTs) implemented in pure Rust.
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
39
40

use cmrdts::{ActorId, AddCtx, CmRDT, Dot, GCounter, VClock};

fn main() {
    // We have two servers logging page views.
    let server1_id = ActorId(1);
    let server2_id = ActorId(2);

    // Each server gets its own GCounter replica.
    let mut server1_views = GCounter::default();
    let mut server2_views = GCounter::default();
    println!("Initial total views: {}", server1_views.read()); // => 0

    // Server 1 logs 10 page views.
    let server1_op_ctx = AddCtx {
        dot: Dot {
            actor: server1_id,
            counter: 1,
        },
        clock: VClock::default(),
    };
    server1_views.apply(cmrdts::g_counter::Op::Inc(10), server1_op_ctx);
    println!("Views on Server 1: {}", server1_views.read());

    // Concurrently, Server 2 logs 15 page views.
    let server2_op_ctx = AddCtx {
        dot: Dot {
            actor: server2_id,
            counter: 1,
        },
        clock: VClock::default(),
    };
    server2_views.apply(cmrdts::g_counter::Op::Inc(15), server2_op_ctx);
    println!("Views on Server 2: {}", server2_views.read());

    // We sync the servers by merging Server 2's data into Server 1.
    server1_views.merge(server2_views);

    // The final value is the sum of all views from all servers.
    println!("Final total views after merge: {}", server1_views.read());
}