Struct MeshConnector 

pub struct MeshConnector { /* private fields */ }

Mesh TCP, with Noise XX when noise is set; mem:// addresses go to registered in-process hosts.

Implementations

impl MeshConnector

pub fn new(noise: bool) -> Self

Connector; noise wraps TCP streams in Noise XX.

pub fn register_local( &self, name: &str, svc: Arc<WorkloadHostService>, ) -> String

Register an in-process host at mem://<name> and return the address. Used for this node’s own host and for Seed adapters on an operator-assigned node id.

Trait Implementations

impl CtlConnector for MeshConnector

fn connect<'life0, 'life1, 'async_trait>( &'life0 self, addr: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn MeshStream>, MeshError>> + Send + 'async_trait>>

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

Connect to addr.

impl Default for MeshConnector

fn default() -> Self

Returns the “default value” for a type.