Struct Hub 

pub struct Hub { /* private fields */ }

Implementations

impl Hub

pub async fn new( tls_config: TlsConfig, listen_addr: String, shutdown: CancellationToken, ) -> Result<Self>

pub fn get_id(&self) -> NodeID

pub fn signing_key(&self) -> Arc<NodeSigningKey>

pub async fn wait_for_shutdown(&self)

pub async fn add_peer(&self, id: &NodeID, addr: &str) -> Result<(), HubError>

pub async fn wait_inbound_ready( &self, id: &NodeID, timeout: Duration, ) -> Result<RequestReceiver, HubError>

pub async fn wait_outbound_ready( &self, id: &NodeID, timeout: Duration, ) -> Result<RequestSender, HubError>

pub async fn remove_peer(&self, id: &NodeID) -> Result<(), HubError>

pub fn outbound(&self, id: &NodeID) -> Result<RequestSender, HubError>

pub fn inbound(&self, id: &NodeID) -> Result<RequestReceiver, HubError>

pub fn rpc_outbound(&self, id: &NodeID) -> Result<RPCSender, HubError>

pub fn rpc_inbound(&self) -> Result<RPCReceiver, HubError>

pub async fn get_peers(&self) -> Vec<NodeID>

Trait Implementations

impl Debug for Hub

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

Formats the value using the given formatter.