Struct LocalProxy 

pub struct LocalProxy { /* private fields */ }

Manages proxying connections to local services

Implementations

impl LocalProxy

pub fn new(connect_timeout: Duration) -> Self

Create a new local proxy with the specified connection timeout

pub fn register_service(&self, service_id: Uuid, config: ServiceConfig)

Register a service for proxying

pub fn unregister_service(&self, service_id: Uuid)

Unregister a service

pub async fn handle_connection( &self, service_id: Uuid, connection_id: Uuid, ) -> Result<TcpStream>

Handle an incoming connection request

This connects to the local service and returns a channel for the data stream. The caller is responsible for connecting the other end (server data channel).

Errors

Returns an error if:

• The service_id is not registered
• Connection to the local service times out
• Connection to the local service fails

pub async fn proxy_streams( local: TcpStream, remote: TcpStream, ) -> Result<(u64, u64)>

Proxy data between two streams bidirectionally

Returns when either side closes or an error occurs. Returns the number of bytes (sent_to_remote, received_from_remote).

Errors

This method does not return errors; it gracefully handles stream closure and I/O errors by terminating the proxy loop.

pub fn start_proxy( &self, connection_id: Uuid, local: TcpStream, remote: TcpStream, ) -> JoinHandle<Result<(u64, u64)>>

Start a proxy task for a connection

Spawns a background task that proxies data between the local and remote streams. The task is automatically cleaned up when the proxy completes or is cancelled.

pub fn cancel_connection(&self, connection_id: Uuid)

Cancel a proxy connection

pub fn connection_count(&self) -> usize

Get count of active connections

pub fn service_count(&self) -> usize

Get count of registered services

pub fn shutdown(&self)

Clean up all connections

Trait Implementations

impl Drop for LocalProxy

fn drop(&mut self)

Executes the destructor for this type.