Struct HydraClient 

pub struct HydraClient { /* private fields */ }

HydraClient connects to the relay server as a producer or consumer, performs handshake, and sends/receives encrypted frames. It maintains an internal memory pool (18 mb) for zero-copy encryption/decryption and buffering. The broadcast method allows producers to send encrypted frames to all connected consumers in the same session, while the recv method allows consumers to receive and decrypt frames from the producer.

Implementations

impl HydraClient

pub async fn connect_producer( addr: SocketAddr, session_id: &[u8; 64], session_key: [u8; 32], ) -> Result<Self>

Connects to the relay server, performs handshake, and sends a join frame with the producer role and session_id.

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

Broadcasts the given data as an encrypted frame to all connected consumers (zero-copy) in the same session. broadcast is only available for producers and will return an error if called on a consumer client.

pub async fn connect_consumer( addr: SocketAddr, session_id: &[u8; 64], session_key: [u8; 32], ) -> Result<Self>

Connects to the relay server, performs handshake, and sends a join frame with the consumer role and session_id.

pub async fn recv(&mut self) -> Result<&[u8]>

Receives the next encrypted frame from the producer, decrypts it, and returns the plaintext data as a byte slice. The returned slice is valid until the next call to recv or broadcast, which may reuse the internal memory pool buffer. recv is only available for consumers and will return an error if called on a producer client.

pub async fn server_status(&mut self) -> Result<()>

Queries the relay server for current status, returns total connected clients and active sessions.

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

Closes the client connection gracefully by flushing and shutting down the writer (proper FIN).