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

use std::fmt;

use crate::progress::entry;
use crate::type_config::alias::LogIdOf;

/// An ID and its associated value.
#[derive(Clone, Debug, PartialEq, Eq)]
pub(crate) struct IdVal<ID, Val> {
    pub(crate) id: ID,
    pub(crate) val: Val,
}

impl<ID, Val> fmt::Display for IdVal<ID, Val>
where
    ID: fmt::Display,
    Val: fmt::Display,
{
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        write!(f, "{}: {}", self.id, self.val)
    }
}

impl<ID, Val> IdVal<ID, Val> {
    pub(crate) fn new(id: ID, val: Val) -> Self {
        Self { id, val }
    }
}

impl<ID, C> IdVal<ID, entry::ProgressEntry<C>>
where
    C: crate::RaftTypeConfig,
    ID: Clone,
{
    /// Return a tuple of (cloned id, cloned matching log id).
    pub(crate) fn to_matching_tuple(&self) -> (ID, Option<LogIdOf<C>>) {
        (self.id.clone(), self.val.matching().cloned())
    }
}