Struct RaftConfig 

pub struct RaftConfig {
    pub node_id: NodeId,
    pub cluster_nodes: Vec<NodeId>,
    pub heartbeat_interval_ms: u64,
    pub election_timeout_min_ms: u64,
    pub election_timeout_max_ms: u64,
    pub max_entries_per_batch: usize,
    pub enable_snapshots: bool,
    pub snapshot_threshold: usize,
    pub max_rpc_retries: usize,
}

Raft node configuration

Fields

node_id: NodeId

This node’s ID

cluster_nodes: Vec<NodeId>

All node IDs in the cluster (including self)

heartbeat_interval_ms: u64

Heartbeat interval in milliseconds

election_timeout_min_ms: u64

Election timeout range (min, max) in milliseconds

election_timeout_max_ms: u64

max_entries_per_batch: usize

Maximum log entries per AppendEntries batch

enable_snapshots: bool

Enable log compaction via snapshotting

snapshot_threshold: usize

Snapshot threshold (entries before snapshot)

max_rpc_retries: usize

Maximum retries for failed RPCs

Implementations

impl RaftConfig

pub fn single_node(node_id: NodeId) -> Self

Create a single-node cluster configuration (useful for testing)

pub fn three_node_cluster(node_id: NodeId) -> Self

Create a three-node cluster configuration

pub fn quorum_size(&self) -> usize

Get 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.

impl Default for RaftConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for RaftConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for RaftConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.