Struct DefaultTransport

pub struct DefaultTransport { /* private fields */ }

A high-level wrapper around a low-level DynTxImp transport implementation.

Implementations

impl DefaultTransport

pub fn create(hnd: &TxImpHnd, imp: DynTxImp) -> DynTransport

When constructing a Transport from a TransportFactory, this function does the actual wrapping of your implemementation to produce the Transport struct.

DefaultTransport is built to be used with the provided TxImpHnd.

Trait Implementations

impl Clone for DefaultTransport

fn clone(&self) -> DefaultTransport

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DefaultTransport

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

Formats the value using the given formatter.

impl Transport for DefaultTransport

fn register_space_handler( &self, space: SpaceId, handler: DynTxSpaceHandler, ) -> Option<Url>

Register a space handler for receiving incoming notifications.

fn register_module_handler( &self, space: SpaceId, module: String, handler: DynTxModuleHandler, )

Register a module handler for receiving incoming module messages.

fn disconnect(&self, peer: Url, reason: Option<String>) -> BoxFut<'_, ()>

Make a best effort to notify a peer that we are disconnecting and why. After a short time out, the connection will be closed even if the disconnect reason message is still pending.

fn send_space_notify( &self, peer: Url, space: SpaceId, data: Bytes, ) -> BoxFut<'_, K2Result<()>>

Notify a remote peer within a space. This is a fire-and-forget type message. The future this call returns will indicate any errors that occur up to the point where the message is handed off to the transport backend. After that, the future will return Ok(()) but the remote peer may or may not actually receive the message.

fn send_module( &self, peer: Url, space: SpaceId, module: String, data: Bytes, ) -> BoxFut<'_, K2Result<()>>

Notify a remote peer module within a space. This is a fire-and-forget type message. The future this call returns will indicate any errors that occur up to the point where the message is handed off to the transport backend. After that, the future will return Ok(()) but the remote peer may or may not actually receive the message.

fn get_connected_peers(&self) -> BoxFut<'_, K2Result<Vec<Url>>>

Get the list of connected peers.

fn unregister_space(&self, space: SpaceId) -> BoxFut<'_, ()>

Unregister a space handler and all module handlers for that space.

fn dump_network_stats(&self) -> BoxFut<'_, K2Result<TransportStats>>

Dump network stats.