Struct TcpStreamService 

pub struct TcpStreamService { /* private fields */ }

TCP stream proxy service

Listens on a port and proxies TCP connections to registered backends using round-robin load balancing.

Implementations

impl TcpStreamService

pub fn new(registry: Arc<StreamRegistry>, listen_port: u16) -> Self

Create a new TCP stream service

pub fn with_tls_acceptor(self, acceptor: TlsAcceptor) -> Self

Enable TLS termination using the given acceptor (builder-style).

pub fn with_proxy_protocol(self, enabled: bool) -> Self

Enable PROXY protocol v2 toward the upstream backend (builder-style).

pub fn port(&self) -> u16

Get the listen port

pub fn registry(&self) -> &Arc<StreamRegistry>

Get a reference to the registry

pub async fn serve(self: Arc<Self>, listener: TcpListener)

Run a standalone TCP accept loop on the given listener.

For each accepted connection, resolves a backend from the registry and spawns a task to perform bidirectional tunneling. This method runs indefinitely until the listener encounters a fatal error.