Struct TransparentProxy 

pub struct TransparentProxy {
    config: ProxyConfig,
    observer: Arc<dyn ProxyObserver>,
    hook: Arc<dyn ProxyHook>,
    cancel: CancellationToken,
    next_session_id: AtomicU64,
}

A transparent MoQT proxy that accepts client connections and forwards traffic to an upstream relay.

Each accepted connection spawns a ProxySession that handles bidirectional stream forwarding with inline MoQT frame parsing.

Fields

config: ProxyConfig

observer: Arc<dyn ProxyObserver>

hook: Arc<dyn ProxyHook>

cancel: CancellationToken

next_session_id: AtomicU64

Implementations

impl TransparentProxy

pub fn new(config: ProxyConfig, observer: Arc<dyn ProxyObserver>) -> Self

Create a new proxy with the given configuration and observer.

pub fn with_hook( config: ProxyConfig, observer: Arc<dyn ProxyObserver>, hook: Arc<dyn ProxyHook>, ) -> Self

Create a new proxy with a custom hook for frame mutation.

pub fn cancel_token(&self) -> CancellationToken

Returns a cancellation token that can be used to trigger shutdown.

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

Run the proxy accept loop. Blocks until cancelled or a fatal listener error occurs.

async fn run_quic(&self) -> Result<(), ProxyError>

Run the QUIC accept loop.

fn next_session_id(&self) -> SessionId

fn emit_session_started(&self, session_id: SessionId, client_addr: SocketAddr)

fn new_session( &self, session_id: SessionId, client_alpn: Vec<u8>, ) -> ProxySession