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

//! I/O flush progress tracking.
//!
//! This module provides watch-based notification channels for tracking when Raft I/O operations
//! (vote saves and log appends) are flushed to storage. It enables applications to:
//!
//! - Wait for specific log entries to be durably written
//! - Track vote changes across leader elections
//! - Ensure data persistence before responding to clients
//!
//! The tracking is based on monotonically increasing [`crate::raft_state::IOId`] values that
//! identify each I/O operation. When storage completes an operation, it notifies RaftCore, which
//! updates the progress channels.

mod flush_point;
mod sender;
mod watch_progress;
mod watcher;

pub use flush_point::FlushPoint;
pub(crate) use sender::IoProgressSender;
pub use watch_progress::AppliedProgress;
pub use watch_progress::CommitProgress;
pub use watch_progress::LogProgress;
pub use watch_progress::SnapshotProgress;
pub use watch_progress::VoteProgress;
pub(crate) use watcher::IoProgressWatcher;