ddcp 0.2.4

Distributed decentralized database-to-database copy
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

@0xc9cb850366986f30;

struct Envelope {
    sender @0 :Text;
    contents @1 :Data;
}

struct Request {
    union {
        status @0 :Void;
        changes @1 :ChangesParams;
    }
}

struct ChangesParams {
    sinceVersion @0 :Int64;
}

struct Response {
    union {
        status @0 :DBStatus;
        changes @1 :ChangesResult;
    }
}

struct ChangesResult {
    siteId @0 :Data;
    changes @1 :List(Change);
}

struct DBStatus {
    siteId @0 :Data;
    dbVersion @1 :Int64;
}

struct NodeStatus {
    db @0 :DBStatus;
    key @1 :Text;
    route @2 :Data;
}

struct Change {
    table @0 :Text;
    pk @1 :Data;
    cid @2 :Text;
    val @3 :ChangeValue;
    colVersion @4 :Int64;
    dbVersion @5 :Int64;
    siteId @6 :Data;
    cl @7 :Int64;
    seq @8 :Int64;
}

struct ChangeValue {
    union {
        null @0 :Void;
        integer @1 :Int64;
        real @2 :Float64;
        text @3 :Text;
        blob @4 :Data;
    }
}