Struct RaftNode 

pub struct RaftNode { /* private fields */ }

Raft node wrapper

Implementations

impl RaftNode

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

Create a new Raft node

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

Propose a new entry

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

Query current state (read-only)

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

Step the Raft state machine with a message

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

Tick the Raft state machine

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