Struct WsProxy 

pub struct WsProxy { /* private fields */ }

WebSocket reverse proxy with round-robin load balancing.

Accepts HTTP/1.1 WebSocket upgrade requests and tunnels traffic to one of the configured backends.

Backend URL schemes:

• "host:port" — plain TCP (no scheme)
• "ws://host:port" — plain TCP (port defaults to 80)
• "wss://host:port" — TLS (port defaults to 443); requires the http-client or http2 Cargo feature

Call WsProxy::bind to start. It blocks the calling thread indefinitely.

Implementations

impl WsProxy

pub fn new<I, S>(backends: I) -> Self

where I: IntoIterator<Item = S>, S: Into<String>,

Create a proxy that distributes connections across backends in round-robin order.

Each entry may be "host:port", "ws://host:port", or "wss://host:port". wss:// requires the http-client or http2 Cargo feature.

pub fn connect_timeout_ms(self, ms: u64) -> Self

Override the TCP connect timeout to each backend (default: 5 s).

pub fn read_timeout_ms(self, ms: u64) -> Self

Override the idle read timeout on client connections (default: 30 s).

For wss:// backends this controls the outer idle timeout on the client side; the internal polling interval is fixed at 5 ms.

pub fn bind(self, addr: &str) -> Result<(), String>

Bind on addr and start proxying WebSocket connections. Blocks indefinitely.