tender 0.1.1

A Raft-based election framework
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

use crate::{ElectionType, VoteResult};
use std::error::Error;

/// Heartbeat request.
#[derive(Debug)]
pub struct HeartbeatRequest<T: ElectionType> {
    pub target_node_id: T::NodeId,
    pub leader_id: T::NodeId,
    pub term: u64,
}

/// Heartbeat response.
#[derive(Debug)]
pub struct HeartbeatResponse<T: ElectionType> {
    pub node_id: T::NodeId,
    pub term: u64,
}

/// Vote request.
#[derive(Debug)]
pub struct VoteRequest<T: ElectionType> {
    pub target_node_id: T::NodeId,
    pub candidate_id: T::NodeId,
    pub vote_id: u64,
    pub term: u64,
    pub factor: T::VoteFactor,
    pub pre_vote: bool,
    pub move_leader: bool,
}

/// Vote response.
#[derive(Debug)]
pub struct VoteResponse<T: ElectionType> {
    pub node_id: T::NodeId,
    pub candidate_id: T::NodeId,
    pub vote_id: u64,
    pub term: u64,
    pub pre_vote: bool,
    pub vote_result: VoteResult,
}

/// MoveLeader request.
#[derive(Debug)]
pub struct MoveLeaderRequest<T: ElectionType> {
    pub target_node_id: T::NodeId,
    pub term: u64,
}

/// RPC interfaces used by election.
pub trait Rpc<T: ElectionType> {
    type Err: Error;

    fn heartbeat(&self, msg: HeartbeatRequest<T>) -> Result<HeartbeatResponse<T>, Self::Err>;
    fn vote(&self, msg: VoteRequest<T>) -> Result<VoteResponse<T>, Self::Err>;
    fn move_leader(&self, msg: MoveLeaderRequest<T>) -> Result<(), Self::Err>;
}