Struct InMemoryConnectionProvider 

pub struct InMemoryConnectionProvider { /* private fields */ }

A connection provider that uses in-memory channels instead of TCP sockets. This implementation uses synchronous data structures with wakers to notify callers expecting to connect or receive a message for example.

This provider can be shared between several StageGraph implementations representing different Amaru nodes communicating together.

Trait Implementations

impl Clone for InMemoryConnectionProvider

fn clone(&self) -> InMemoryConnectionProvider

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ConnectionProvider for InMemoryConnectionProvider

fn listen(&self, addr: SocketAddr) -> BoxFuture<'static, Result<SocketAddr>>

Create a new listener for the given address. If a listener already exists for this address, it is removed to allow supervised restarts.

fn accept( &self, listener_addr: SocketAddr, ) -> BoxFuture<'static, Result<(Peer, ConnectionId)>>

Accept an incoming connection for the specified listener. Returns the peer and connection ID. If no peer is currently trying to connect, this waits until a connection is available and wakes the caller.

fn connect( &self, addr: Vec<SocketAddr>, _timeout: Duration, ) -> BoxFuture<'static, Result<ConnectionId>>

Connect to one of the given addresses. If a listener for the target address is already registered, the connection is established immediately.

This creates 2 connection endpoints with shared read / write queues.

fn connect_addrs( &self, addr: ToSocketAddrs, timeout: Duration, ) -> BoxFuture<'static, Result<ConnectionId>>

Connect to a given peer, at a list of SocketAddr.

fn send( &self, conn: ConnectionId, data: NonEmptyBytes, ) -> BoxFuture<'static, Result<()>>

Send a message to the connection peer:

• Add bytes to the connection write_queue (this is the read_queue of the peer on its connection)
• Wake the peer so that it can read the data.

fn recv( &self, conn: ConnectionId, bytes: NonZeroUsize, ) -> BoxFuture<'static, Result<NonEmptyBytes>>

Receive a new message by reading from the message queue when a new message has arrived

fn close(&self, conn: ConnectionId) -> BoxFuture<'static, Result<()>>

Close a connection, given its connection id. This removes the corresponding endpoint from the endpoints map and also removes the peer’s endpoint so that both sides get notified of the closure. Closing an already-closed connection is a no-op (idempotent).

impl Default for InMemoryConnectionProvider

fn default() -> InMemoryConnectionProvider

Returns the “default value” for a type.