Struct raft4rs::raft::Raft

pub struct Raft {
    pub id: u64,
    pub applied: AtomicU64,
    pub store: RaftLog,
    pub replicas: RwLock<Vec<u64>>,
    pub resolver: RSL,
    // some fields omitted
}

Fields

id: u64

applied: AtomicU64

store: RaftLog

replicas: RwLock<Vec<u64>>

resolver: RSL

Implementations

impl Raft

pub async fn new(
    id: u64,
    start_index: u64,
    conf: Arc<Config>,
    replicas: Vec<u64>,
    resolver: RSL,
    sm: SM
) -> RaftResult<Arc<Self>>

id is raft id: it unique in diff raft group start_index: to add member when raft group exists . set it for playback log not remove self it first to load it by disk , if not exists use by your set, if you unknow how to set , set it 0 conf is raft config replicas all members in raft group . resolver to find addr by node_id callback for app

pub async fn notify<'_>(self: &'_ Raft)

pub async fn execute<'_>(
    self: &'_ Arc<Raft>,
    cmd: Vec<u8>,
    forward_leader: bool
) -> RaftResult<Vec<u8>>

pub async fn submit<'_>(
    self: &'_ Arc<Raft>,
    cmd: Vec<u8>,
    forward_leader: bool
) -> RaftResult<()>

pub async fn add_member<'_>(self: &'_ Arc<Raft>, node_id: u64) -> RaftResult<()>

pub async fn remove_member<'_>(
    self: &'_ Arc<Raft>,
    node_id: u64
) -> RaftResult<()>

pub async fn apply<'_, '_>(
    self: &'_ Arc<Raft>,
    entry: &'_ Entry
) -> RaftResult<()>

pub fn get_resolver(&self) -> &RSL

pub async fn heartbeat<'_>(
    &'_ self,
    term: u64,
    leader: u64,
    committed: u64,
    applied: u64
) -> RaftResult<()>

pub async fn vote<'_>(
    &'_ self,
    leader: u64,
    term: u64,
    committed: u64
) -> RaftResult<()>

pub async fn leader_change<'_>(
    &'_ self,
    term: u64,
    index: u64,
    leader: u64
) -> RaftResult<()>

pub async fn is_follower<'_>(&'_ self) -> bool

pub async fn is_leader<'_>(&'_ self) -> bool

pub fn leader(&self) -> u64

pub async fn is_candidate<'_>(&'_ self) -> bool

pub async fn get_state<'_>(&'_ self) -> RaftState

pub fn is_stoped(&self) -> bool

pub async fn update_apply<'_>(&'_ self, term: u64, index: u64) -> RaftResult<()>

pub async fn info<'_>(&'_ self) -> RaftInfo

impl Raft

pub async fn try_to_leader<'_>(self: &'_ Arc<Raft>) -> RaftResult<bool>

pub async fn to_follower<'_>(&'_ self)

impl Raft

pub fn start(self: &Arc<Raft>)