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

use crate::RaftTypeConfig;
use crate::raft_state::IOId;
use crate::replication::replicate::Replicate;
use crate::type_config::alias::LogIdOf;
use crate::type_config::alias::WatchReceiverOf;

#[derive(Clone)]
pub(crate) struct EventWatcher<C>
where C: RaftTypeConfig
{
    pub(crate) replicate_rx: WatchReceiverOf<C, Replicate<C>>,
    pub(crate) committed_rx: WatchReceiverOf<C, Option<LogIdOf<C>>>,

    pub(crate) io_accepted_rx: WatchReceiverOf<C, IOId<C>>,
    pub(crate) io_submitted_rx: WatchReceiverOf<C, IOId<C>>,
}