Struct HydraServer 

pub struct HydraServer { /* private fields */ }

HydraServer- A light-weight, E2E (AES-GCM), multi-threaded SPMC broadcast server using TCP. It implements internal ring buffer configured by HydraConfig, uses little memory and minimal copy as possible.

use hydra_sync::server::HydraServer;

#[tokio::main]
async fn main() {
    let (server, addr) = HydraServer::bind_default().await.unwrap();
    println!("Server running on: {}", addr);
    tokio::spawn(async move { server.run().await });
}

Implementations

impl HydraServer

pub async fn bind_default() -> Result<(Self, SocketAddr)>

Binds the server with random local port and default HydraConfig, returns the port.

pub async fn bind( socket_addr: SocketAddr, hydra_config: HydraConfig, ) -> Result<(Self, SocketAddr)>

Binds the server to the specified SocketAddr with the provided HydraConfig.

pub async fn run(&self) -> Result<()>

Starts the server, accepting incoming connections and handling them concurrently. Overview:

• Accept incoming TCP connections, spawn handler tasks and allocate read/write buffers or reject if max connections reached.
• Perform handshake, read/decrypt JoinHeader, determine role (Producer/Consumer/Admin).
• For Producers: Create valid session, read data (exactly fixed_packet_length, including AES-GCM (28 bytes) overhead, with read_exact(), so it may truncate) and broadcast (cheap-copy) to all Consumers in the session (Write behavior is configured by ChannelOverflowStrategy).
• For Consumers: Validate session, read from local ring buffer from producer handle, write to TCP stream.
• LOG_LEVEL & LOG_FILE_DIR env vars can be set to control logging verbosity and output file (defaults to info level and stdout and file).
• EOF check are gracefully handled by closing the connection without logging an error.

pub async fn shutdown(&self) -> Result<()>