Struct safe_core::ConnectionManager

pub struct ConnectionManager { /* fields omitted */ }

Initialises QuicP2p instance. Establishes new connections. Contains a reference to crossbeam channel provided by quic-p2p for capturing the events.

Implementations

impl ConnectionManager

pub fn new(config: QuicP2pConfig, net_tx: &NetworkTx) -> Result<Self, CoreError>

Create a new connection manager.

pub async fn has_connection_to<'_, '_>(&'_ self, pub_id: &'_ PublicId) -> bool

Returns true if this connection manager is already connected to a Client Handlers group serving the provided public ID.

pub async fn send<'_, '_, '_>(
    &'_ mut self,
    pub_id: &'_ PublicId,
    msg: &'_ Message
) -> Result<Response, CoreError>

Send message via the ConnectionGroup specified by our given pub_id.

pub async fn bootstrap<'_>(
    &'_ mut self,
    full_id: SafeKey
) -> Result<(), CoreError>

Connect to Client Handlers that manage the provided ID.

pub fn restart_network(&mut self)

Reconnect to the network.

pub async fn disconnect<'_, '_>(
    &'_ mut self,
    pub_id: &'_ PublicId
) -> Result<(), CoreError>

Disconnect from a group.

Trait Implementations

impl Clone for ConnectionManager

fn clone(&self) -> ConnectionManager

Returns a copy of the value.

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

Performs copy-assignment from source.