araft 0.1.0

An async raft implementation based on tokio + tonic
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
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64

syntax = "proto3";

package internal;

message AppendEntriesIn {
    message Entry {
        message Set {
            string key = 1;
            string value = 2;
        }

        message Remove {
            string key = 1;
        }

        oneof operation {
            Set set = 1;
            Remove remove = 2;
        }
    }

    uint64 term = 1;
    string leader_id = 2;
    uint64 prev_log_index = 3;
    uint64 prev_log_term = 4;
    repeated Entry entries = 5;
    uint64 leader_commit = 6;
}

message AppendEntriesOut {
    uint64 term = 1;
    bool success = 2;
}

message RequestVoteIn {
    uint64 term = 1;
    string candidate_id = 2;
    uint64 last_log_index = 3;
    uint64 last_log_term = 4;
}

message RequestVoteOut {
    uint64 term = 1;
    bool vote_granted = 2;
}

message EchoIn {
    string name = 1;
}

message EchoOut {
    string message = 1;
}

service RaftInternal {
    rpc AppendEntries(AppendEntriesIn)
        returns (AppendEntriesOut);

    rpc RequestVote(RequestVoteIn)
        returns (RequestVoteOut);

    rpc Echo(EchoIn)
        returns (EchoOut);
}