Struct TcpNetwork 

pub struct TcpNetwork { /* private fields */ }

TCP Network implementation

Implementations

impl TcpNetwork

pub async fn new(node_id: NodeId, config: TcpNetworkConfig) -> Result<Self>

Create a new TCP network instance

pub async fn connect_to_peer( &self, peer_node_id: NodeId, addr: SocketAddr, ) -> Result<()>

Connect to a peer node

pub fn local_addr(&self) -> SocketAddr

Get the local bind address

pub fn node_id(&self) -> NodeId

Get this node’s ID

pub async fn add_peer(&mut self, node_id: NodeId, addr: SocketAddr)

Add a known peer address for automatic connection

pub async fn remove_peer(&mut self, node_id: NodeId)

Remove a peer

pub async fn shutdown(&self)

Shutdown the network

Trait Implementations

impl Clone for TcpNetwork

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl NetworkTransport for TcpNetwork

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

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

fn broadcast<'life0, 'async_trait>( &'life0 self, message: ProtocolMessage, exclude: Option<NodeId>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

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

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

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

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

fn is_connected<'life0, 'async_trait>( &'life0 self, node_id: NodeId, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

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

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

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

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