Struct InMemoryTransport 

pub struct InMemoryTransport { /* private fields */ }

In-memory transport for testing and local development

Provides a zero-copy, high-performance transport for running multiple RAFT nodes in the same process.

Implementations

impl InMemoryTransport

pub fn new( node_id: NodeId, registry: Arc<DashMap<NodeId, UnboundedSender<(NodeId, Message)>>>, ) -> Self

Create a new in-memory transport for a node

Arguments

• node_id - Unique identifier for this node
• registry - Shared registry of all nodes in the cluster

pub fn new_registry() -> Arc<DashMap<NodeId, UnboundedSender<(NodeId, Message)>>>

Create a new registry for a cluster

Trait Implementations

impl Transport for InMemoryTransport

fn send<'life0, 'async_trait>( &'life0 self, target: NodeId, message: Message, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Send a message to a specific node

fn recv<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(NodeId, Message)>> + Send + 'async_trait>>

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

Receive the next message for this node

fn node_id(&self) -> NodeId

Get local node ID

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

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

Close the transport and clean up resources