openraft 0.10.0-alpha.18

Advanced Raft consensus
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

//! Testing utilities used by all kinds of tests.

use std::collections::BTreeSet;

use crate::RaftTypeConfig;
use crate::entry::RaftEntry;
use crate::type_config::alias::EntryOf;
use crate::type_config::alias::LogIdOf;
use crate::vote::RaftLeaderIdExt;

/// Builds a log id, for testing purposes.
pub fn log_id<C>(term: u64, node_id: C::NodeId, index: u64) -> LogIdOf<C>
where
    C: RaftTypeConfig,
    C::Term: From<u64>,
{
    LogIdOf::<C>::new(C::LeaderId::new_committed(term.into(), node_id), index)
}

/// Create a blank log entry for tests.
pub fn blank_ent<C>(term: u64, node_id: C::NodeId, index: u64) -> EntryOf<C>
where
    C: RaftTypeConfig,
    C::Term: From<u64>,
{
    EntryOf::<C>::new_blank(log_id::<C>(term, node_id, index))
}

/// Create a membership log entry without learner config for test.
pub fn membership_ent<C>(term: u64, node_id: C::NodeId, index: u64, config: Vec<BTreeSet<C::NodeId>>) -> EntryOf<C>
where
    C: RaftTypeConfig,
    C::Term: From<u64>,
    C::Node: Default,
{
    EntryOf::<C>::new_membership(
        log_id::<C>(term, node_id, index),
        crate::Membership::new_with_defaults(config, []),
    )
}