Struct NetworkManager 

pub struct NetworkManager { /* private fields */ }

Network manager for Raft communication

This component manages the network layer for Raft messages, handling both sending and receiving messages between nodes.

Implementations

impl NetworkManager

pub fn new(config: Arc<ControllerConfig>) -> (Self, UnboundedReceiver<Message>)

Create a new network manager

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

Start the network manager

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

Shutdown the network manager

pub fn incoming_sender(&self) -> UnboundedSender<Message>

Get the incoming message sender

pub async fn send_message(&self, msg: Message) -> Result<()>

Send a message to a peer

pub async fn broadcast_message(&self, msg: Message) -> Result<()>

Broadcast a message to all peers