Struct NodeSession 

pub struct NodeSession { /* private fields */ }

Implementations

impl NodeSession

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>

Dial a dedicated uplink, OPEN one channel, and complete the Noise_NK handshake.

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

The shared uplink this session rides on (to open sibling channels).

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

Encrypt and send one inner message toward core.

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

Next decrypted message from core.

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

Request/response helper for node calls (mail.*, task.*). The node id is never in the payload: core takes it from the stream the envelope arrived on.