Struct NodeUplink 

pub struct NodeUplink { /* private fields */ }

One TCP uplink to C2 carrying any number of channels.

Implementations

impl NodeUplink

pub async fn connect( uplink: SocketAddr, journal: Option<Arc<UplinkJournal>>, ) -> Result<Arc<Self>, String>

pub fn is_alive(&self) -> bool

pub async fn closed(&self)

Wait until the uplink is marked dead (write timeout / peer close).

pub async fn open( self: &Arc<Self>, node_id: &str, channel_id: u32, kind: ChannelKind, keys: UpstreamKeys, handshake_timeout: Duration, ) -> Result<NodeSession, String>

OPEN channel_id, wait for WINDOW credit, then complete Noise_NK.

Trait Implementations

impl Drop for NodeUplink

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.