Struct RaftTransport 

pub struct RaftTransport { /* private fields */ }

Network transport for Raft

Implementations

impl RaftTransport

pub fn new( node_id: u64, listen_addr: SocketAddr, peer_addrs: HashMap<u64, SocketAddr>, ) -> (Self, UnboundedReceiver<Message>, UnboundedReceiver<Message>)

Create a new transport

pub async fn start(self: Arc<Self>) -> Result<()>

Start the transport

pub async fn send_to_peer(&self, peer_id: u64, msg: Message) -> Result<()>

Send a message to a specific peer

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

Broadcast a message to all peers

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

Get the message sender