Struct InMemoryNetwork 

pub struct InMemoryNetwork<T> { /* private fields */ }

In-memory network transport for testing.

Implementations

impl<T: Send + Sync + Clone + 'static> InMemoryNetwork<T>

pub fn new(node_id: NodeId, inbox_rx: Receiver<RaftMessage<T>>) -> Self

Creates a new in-memory network node.

pub async fn register_peer( &self, peer_id: NodeId, address: String, sender: Sender<RaftMessage<T>>, )

Registers a peer’s outbox for sending messages.

Trait Implementations

impl<T: Send + Sync + Clone + Serialize + DeserializeOwned + 'static> RaftNetwork<T> for InMemoryNetwork<T>

fn send_request_vote<'life0, 'async_trait>( &'life0 self, peer_id: NodeId, term: Term, candidate_id: NodeId, last_log_index: LogIndex, last_log_term: Term, ) -> Pin<Box<dyn Future<Output = Result<Option<RaftMessage<T>>, NetworkError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sends a RequestVote RPC to a specific peer.

fn send_append_entries<'life0, 'async_trait>( &'life0 self, peer_id: NodeId, term: Term, leader_id: NodeId, prev_log_index: LogIndex, prev_log_term: Term, entries: Vec<LogEntry<T>>, leader_commit: LogIndex, ) -> Pin<Box<dyn Future<Output = Result<Option<RaftMessage<T>>, NetworkError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sends an AppendEntries RPC to a specific peer.

fn send_install_snapshot<'life0, 'async_trait>( &'life0 self, peer_id: NodeId, term: Term, leader_id: NodeId, snapshot: Snapshot<T>, ) -> Pin<Box<dyn Future<Output = Result<Option<RaftMessage<T>>, NetworkError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sends an InstallSnapshot RPC to a specific peer.

fn receive<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<RaftMessage<T>, NetworkError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Receives the next incoming RPC message.

fn respond<'life0, 'async_trait>( &'life0 self, to: NodeId, message: RaftMessage<T>, ) -> Pin<Box<dyn Future<Output = Result<(), NetworkError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Responds to an incoming RPC.

fn peer_ids(&self) -> Vec<NodeId>

Gets the list of peer IDs.

fn update_peers<'life0, 'async_trait>( &'life0 self, peers: Vec<PeerInfo>, ) -> Pin<Box<dyn Future<Output = Result<(), NetworkError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Updates the peer list.