Struct NodeSession 

pub struct NodeSession { /* private fields */ }

Implementations

impl NodeSession

pub fn udp_available(&self) -> bool

Whether this uplink has a connected UDP socket and the data plane is enabled.

pub fn set_udp(&mut self, on: bool)

Route this session’s SendPrio::Pty DATA over UDP. Set once, right after open, before any transport frame: switching later would reorder Noise nonces.

pub fn udp(&self) -> bool

pub async fn connect( uplink: SocketAddr, node_id: &str, channel_id: u32, kind: ChannelKind, keys: UpstreamKeys, journal: Option<Arc<UplinkJournal>>, handshake_timeout: Duration, ) -> Result<Self, String>

pub fn uplink(&self) -> Arc<NodeUplink>

pub async fn send(&mut self, plaintext: &[u8]) -> Result<(), String>

pub async fn send_prio( &mut self, plaintext: &[u8], prio: SendPrio, ) -> Result<(), String>

pub async fn recv(&mut self, timeout: Duration) -> Result<Vec<u8>, String>

pub async fn call( &mut self, op: &str, payload: &Value, timeout: Duration, ) -> Result<Value, String>