Struct VCLConnection 

pub struct VCLConnection { /* private fields */ }

Implementations

impl VCLConnection

pub async fn bind(addr: &str) -> Result<Self, VCLError>

pub fn subscribe(&mut self) -> Receiver<VCLEvent>

Subscribe to connection events. Returns an async receiver channel. Call before connect() / accept_handshake() to catch Connected event.

pub fn set_timeout(&mut self, secs: u64)

pub fn get_timeout(&self) -> u64

pub fn last_activity(&self) -> Instant

pub fn set_shared_key(&mut self, private_key: &[u8])

pub async fn connect(&mut self, addr: &str) -> Result<(), VCLError>

pub async fn accept_handshake(&mut self) -> Result<(), VCLError>

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

pub async fn ping(&mut self) -> Result<(), VCLError>

Send a ping to the peer. The pong reply is handled automatically inside recv() — subscribe to events to receive PongReceived { latency }. You must keep calling recv() for the pong to be processed.

pub async fn rotate_keys(&mut self) -> Result<(), VCLError>

Initiate a key rotation. Generates a new X25519 ephemeral key pair, sends the public key to the peer, and waits for the peer’s response. Both sides atomically switch to the new shared secret. The peer must be in an active recv() loop to handle the rotation.

pub async fn recv(&mut self) -> Result<VCLPacket, VCLError>

pub fn close(&mut self) -> Result<(), VCLError>

pub fn is_closed(&self) -> bool

pub fn get_public_key(&self) -> Vec<u8>

pub fn get_shared_secret(&self) -> Option<[u8; 32]>