Struct RaftController 

pub struct RaftController { /* private fields */ }

Raft controller - replaces Java DLedger

This component provides distributed consensus using the Raft algorithm. It manages:

• Leader election
• Log replication
• Snapshot management
• State machine application
• Network communication

Implementations

impl RaftController

pub async fn new(config: Arc<ControllerConfig>) -> Result<Self>

Create a new Raft controller

pub async fn start(&self) -> Result<()>

Start the Raft controller

pub async fn shutdown(&self) -> Result<()>

Shutdown the Raft controller

pub async fn propose(&self, data: Vec<u8>) -> Result<Vec<u8>>

Propose a new entry (write operation)

pub async fn query(&self, data: Vec<u8>) -> Result<Vec<u8>>

Query current state (read-only operation)

pub async fn is_leader(&self) -> bool

Check if this node is the leader

pub async fn get_leader(&self) -> Option<u64>

Get the current leader ID

pub async fn step(&self, message: Message) -> Result<()>

Handle a Raft message from a peer