Struct ockam_transport_tcp::TcpTransport

pub struct TcpTransport { /* fields omitted */ }

High level management interface for TCP transports

Be aware that only one TcpTransport can exist per node, as it registers itself as a router for the TCP address type. Multiple calls to TcpTransport::create will fail.

To register additional connections on an already initialised TcpTransport, use tcp.connect(). To listen for incoming connections use tcp.listen()

use ockam_transport_tcp::TcpTransport;
let tcp = TcpTransport::create(&ctx).await?;
tcp.listen("127.0.0.1:8000").await?; // Listen on port 8000
tcp.connect("127.0.0.1:5000").await?; // And connect to port 5000

The same TcpTransport can also bind to multiple ports.

let tcp = TcpTransport::create(&ctx).await?;
tcp.listen("127.0.0.1:8000").await?; // Listen on port 8000
tcp.listen("127.0.0.1:9000").await?; // Listen on port 9000

Implementations

impl TcpTransport

pub async fn create(ctx: &Context) -> Result<Self>

Create a new TCP transport and router for the current node

pub async fn connect(&self, peer: impl Into<String>) -> Result<()>

Establish an outgoing TCP connection on an existing transport

pub async fn listen(&self, bind_addr: impl Into<String>) -> Result<()>

Start listening to incoming connections on an existing transport

impl TcpTransport

pub async fn create_inlet(
    &self,
    bind_addr: impl Into<String>,
    onward_route: impl Into<Route>
) -> Result<Address>

Create Tcp Inlet that listens on bind_addr, transforms Tcp stream into Ockam Routable Messages and forward them to Outlet using onward_route. Inlet is bidirectional: Ockam Messages sent to Inlet from Outlet (using return route) will be streamed to Tcp connection. Pair of corresponding Inlet and Outlet is called Portal.

pub async fn stop_inlet(&self, addr: impl Into<Address>) -> Result<()>

Stop inlet at addr

pub async fn create_outlet(
    &self,
    address: impl Into<Address>,
    peer: impl Into<String>
) -> Result<()>

Create Tcp Outlet Listener at address, that connects to peer using Tcp, transforms Ockam Messages received from Inlet into stream and sends it to peer Tcp stream. Outlet is bidirectional: Tcp stream received from peer is transformed into Ockam Routable Messages and sent to Inlet using return route. Pair of corresponding Inlet and Outlet is called Portal.

Trait Implementations

impl Clone for TcpTransport

fn clone(&self) -> TcpTransport

Returns a copy of the value.

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

Performs copy-assignment from source.