Struct QuicMitmIngress 

pub struct QuicMitmIngress { /* private fields */ }

Available on crate features quic and std only.

Coordinate migration between platform flows without sharing connection endpoints.

Use one instance per trusted policy identity boundary. Install it with super::super::PeekQuicClientHelloService::with_router and pass the same instance to super::QuicMitmRelay::with_migration_ingress. Each intercepted connection registers its own native endpoint. CID matches are routing hints, never authentication; a stale match is dropped rather than passed to policy. Scope admitted MITM work with run_connection.

Implementations

impl QuicMitmIngress

pub fn new( scope: impl Into<WeakScope>, config: QuicMitmIngressConfig, ) -> QuicMitmIngress

Configure one policy identity boundary. Use an application/provider scope, not a platform flow’s scope: logical connections must survive the original flow closing.

pub async fn run_connection<O>( &self, connection: impl Future<Output = Result<O, Box<dyn Error + Send + Sync>>> + Send + 'static, ) -> Result<O, Box<dyn Error + Send + Sync>>

where O: Send + 'static,

Run an admitted MITM connection in the provider scope, independently of its first platform flow. Call only after policy selects interception; raw forwarding should retain its caller’s cancellation. Move admission permits and other lifetime guards into connection, so cancelling the caller cannot release them prematurely.

pub fn is_idle(&self) -> bool

Whether this is the last handle and no path, connection or acquisition needs its endpoints. Useful for evicting idle policy identities from an application’s bounded cache. A false result may become true later; callers must still serialize their cache access.

Trait Implementations

impl Clone for QuicMitmIngress

fn clone(&self) -> QuicMitmIngress

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for QuicMitmIngress

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl QuicPeekRouter<()> for QuicMitmIngress

type Route = QuicMitmRoute

fn route<Socket>( &self, socket: &Socket, metadata: &DatagramMetadata, data: &[u8], ) -> Result<Option<QuicMitmRoute>, Box<dyn Error + Send + Sync>>

where Socket: DatagramSocket,