viewstamped-replication 0.9.0

A Rust-based implementation of the Viewstamped Replication consensus 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
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

use crate::protocol::{
    Commit, DoViewChange, GetState, NewState, Prepare, PrepareOk, Recovery, RecoveryResponse,
    StartView, StartViewChange,
};
use crate::request::{ClientIdentifier, Reply};
use crate::service::Protocol;

pub trait Outbox<P>
where
    P: Protocol,
{
    fn prepare(&mut self, message: Prepare<P::Request, P::Prediction>);

    fn prepare_ok(&mut self, index: usize, message: PrepareOk);

    fn commit(&mut self, message: Commit);

    fn get_state(&mut self, index: usize, message: GetState);

    fn new_state(&mut self, index: usize, message: NewState<P::Request, P::Prediction>);

    fn start_view_change(&mut self, message: StartViewChange);

    fn do_view_change(&mut self, index: usize, message: DoViewChange<P::Request, P::Prediction>);

    fn start_view(&mut self, message: StartView<P::Request, P::Prediction>);

    fn recovery(&mut self, message: Recovery);

    fn recovery_response(
        &mut self,
        index: usize,
        message: RecoveryResponse<P::Request, P::Prediction>,
    );

    fn reply(&mut self, client: ClientIdentifier, reply: &Reply<P::Reply>);
}

pub trait Inbox<P>
where
    P: Protocol,
{
    fn push_prepare(&mut self, message: Prepare<P::Request, P::Prediction>);

    fn push_prepare_ok(&mut self, message: PrepareOk);

    fn push_commit(&mut self, message: Commit);

    fn push_get_state(&mut self, message: GetState);

    fn push_new_state(&mut self, message: NewState<P::Request, P::Prediction>);

    fn push_start_view_change(&mut self, message: StartViewChange);

    fn push_do_view_change(&mut self, message: DoViewChange<P::Request, P::Prediction>);

    fn push_start_view(&mut self, message: StartView<P::Request, P::Prediction>);

    fn push_recovery(&mut self, message: Recovery);

    fn push_recovery_response(&mut self, message: RecoveryResponse<P::Request, P::Prediction>);
}

pub trait Mailbox<P>: Inbox<P> + Outbox<P>
where
    P: Protocol,
{
}