Struct Endpoint

pub struct Endpoint { /* private fields */ }

Implementations

impl Endpoint

pub async fn new( addr: &str, port: u16, name: &str, mode: Mode, ) -> Result<Arc<Self>>

Create a new endpoint on an interface and port

pub fn mode(&self) -> Mode

Get the current runtime mode

pub async fn stop(&self)

pub async fn add_peers(&self, peers: Vec<String>) -> Result<()>

Insert a set of peers into the routing table

Each peer will spawn a worker that periodically attempts to connect to it. Connections might not be recipricated if the peer doesn’t know the local IP or is rejecting unknown connections.

Trait Implementations

impl Clone for Endpoint

fn clone(&self) -> Endpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Endpoint for Endpoint

fn size_hint(&self) -> usize

Return a desired frame size in bytes

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

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

Dispatch a Frame across this link

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

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

Poll for the next available Frame from this interface