Struct MemoryTransport 

pub struct MemoryTransport { /* private fields */ }

An in-memory RaftTransport that records outgoing messages.

Instead of delivering anywhere, it appends each message to an outbox that a test harness drains with take and routes to the destination node by hand. This makes message ordering, loss, and partitions something the test controls precisely.

Examples

use raft_io::{MemoryTransport, RaftTransport, Message, AppendEntries};

let mut tx = MemoryTransport::new();
tx.send(2, Message::AppendEntries(AppendEntries {
    term: 1, leader: 1, prev_log_index: 0, prev_log_term: 0,
    entries: Vec::new(), leader_commit: 0,
})).unwrap();

let pending = tx.take();
assert_eq!(pending[0].0, 2);          // destination
assert!(tx.take().is_empty());        // draining leaves it empty

Implementations

impl MemoryTransport

pub fn new() -> Self

Creates an empty transport.

pub fn take(&mut self) -> Vec<(NodeId, Message)>

Removes and returns every queued (destination, message) pair.

Examples

use raft_io::MemoryTransport;

let mut tx = MemoryTransport::new();
assert!(tx.take().is_empty());

pub fn pending(&self) -> usize

Returns the number of queued messages without draining them.

Trait Implementations

impl Clone for MemoryTransport

fn clone(&self) -> MemoryTransport

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MemoryTransport

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for MemoryTransport

fn default() -> MemoryTransport

Returns the “default value” for a type.

impl RaftTransport for MemoryTransport

fn send(&mut self, to: NodeId, message: Message) -> Result<()>

Delivers message to node to.