Struct RaftConfig 

pub struct RaftConfig {

    pub node_id: NodeId,
    pub peers: Vec<NodeId>,
    pub election_timeout_range: (u64, u64),
    pub heartbeat_interval: u64,
    pub max_entries_per_message: usize,
    pub enable_compaction: bool,
    pub snapshot_threshold: u64,
    pub max_snapshots: usize,
    pub snapshot_dir: Option<PathBuf>,
    pub persistence_dir: Option<PathBuf>,
    pub wal_dir: Option<PathBuf>,
    pub sync_on_write: bool,
    pub snapshot_chunk_threshold_bytes: u64,
    pub snapshot_chunk_size_bytes: usize,
}

Configuration for a Raft node

Fields

node_id: NodeId

This node’s ID

peers: Vec<NodeId>

List of all peer node IDs (including this node)

election_timeout_range: (u64, u64)

Election timeout range (min, max) in milliseconds

heartbeat_interval: u64

Heartbeat interval in milliseconds

max_entries_per_message: usize

Maximum number of entries to send in a single AppendEntries RPC

enable_compaction: bool

Whether to enable log compaction

snapshot_threshold: u64

Snapshot threshold (number of log entries before triggering snapshot)

max_snapshots: usize

Maximum number of snapshots to retain on disk

snapshot_dir: Option<PathBuf>

Directory for storing snapshots (None = snapshots disabled on disk)

persistence_dir: Option<PathBuf>

Directory for Raft persistent state and log (None = in-memory only)

wal_dir: Option<PathBuf>

Directory for segment-based WAL replay on startup (None = WAL replay disabled)

sync_on_write: bool

Whether to fsync after every persistent write (default: true)

snapshot_chunk_threshold_bytes: u64

Max snapshot size in bytes before switching to chunked streaming. Default: 4 MiB.

snapshot_chunk_size_bytes: usize

Chunk size in bytes for large snapshot streaming. Default: 1 MiB.

Implementations

impl RaftConfig

pub fn new(node_id: NodeId, peers: Vec<NodeId>) -> Self

Create a new Raft configuration with sensible defaults

pub fn random_election_timeout(&self) -> Duration

Get a random election timeout within the configured range

pub fn heartbeat_interval(&self) -> Duration

Get the heartbeat interval

pub fn validate(&self) -> Result<(), String>

Validate the configuration

pub fn quorum_size(&self) -> usize

Calculate the quorum size (majority)

Trait Implementations

impl Clone for RaftConfig

fn clone(&self) -> RaftConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RaftConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.