Struct PeekQuicClientHelloService 

pub struct PeekQuicClientHelloService<K, S, F = RejectService<(), NoQuicRejectError>> { /* private fields */ }

Available on crate features quic and std only.

Inspects the first datagrams of a UDP association for a QUIC client’s Initial flight and its ClientHello, then hands the association on with those datagrams replayed in front.

A complete ClientHello goes to the inner service as InputWithQuicClientHello. Anything else ends in a QuicPeekRejection: classes the QuicPeekFallbackPolicy admits go to the fallback with the same datagrams intact and the rejection in the input’s extensions, so the fallback can still forward the association untouched; the others fail with QuicPeekRejectedError. Nothing is ever sent while peeking: the decision is made before any local QUIC output exists. The deadline is absolute from serve, and the read ahead is bounded by CaptureLimits.

Routing sees the outer ClientHello only: with ECH that is the public name, never the encrypted inner one. 0-RTT in the first flight is never decrypted: it is flagged as PeekedClientHello::early_data_observed and replayed untouched to a forwarding service, while a terminating relay rejects it and the client resends that data after the handshake.

The fallback rejects by default; use Self::with_fallback to forward instead.

Implementations

impl<K, S> PeekQuicClientHelloService<K, S>

pub fn new(keys: K, inner: S) -> PeekQuicClientHelloService<K, S>

Peek with keys deriving the Initial keys of the client’s offered version. No certificate or server identity is needed.

impl<K, S, F> PeekQuicClientHelloService<K, S, F>

pub fn with_fallback<G>( self, fallback: G, ) -> PeekQuicClientHelloService<K, S, G>

Hand associations the fallback policy admits to fallback.

pub fn with_first_flight_retention( self, retain: bool, ) -> PeekQuicClientHelloService<K, S, F>

Retain structural facts through the datagram completing ClientHello (default: on). A native mirror uses these facts for fresh Initial packetization and CID lengths.

pub fn set_first_flight_retention( &mut self, retain: bool, ) -> &mut PeekQuicClientHelloService<K, S, F>

Retain structural facts through the datagram completing ClientHello (default: on). A native mirror uses these facts for fresh Initial packetization and CID lengths.

pub fn with_limits( self, limits: CaptureLimits, ) -> PeekQuicClientHelloService<K, S, F>

Bounds on the datagrams, packets and bytes read ahead.

pub fn set_limits( &mut self, limits: CaptureLimits, ) -> &mut PeekQuicClientHelloService<K, S, F>

Bounds on the datagrams, packets and bytes read ahead.

pub fn with_peek_timeout( self, timeout: Duration, ) -> PeekQuicClientHelloService<K, S, F>

How long the whole inspection may take, from serve. Defaults to DEFAULT_QUIC_PEEK_TIMEOUT.

pub fn set_peek_timeout( &mut self, timeout: Duration, ) -> &mut PeekQuicClientHelloService<K, S, F>

How long the whole inspection may take, from serve. Defaults to DEFAULT_QUIC_PEEK_TIMEOUT.

pub fn with_fallback_policy( self, policy: QuicPeekFallbackPolicy, ) -> PeekQuicClientHelloService<K, S, F>

Which rejections reach the fallback. Defaults to QuicPeekFallbackPolicy::NOT_QUIC.

pub fn set_fallback_policy( &mut self, policy: QuicPeekFallbackPolicy, ) -> &mut PeekQuicClientHelloService<K, S, F>

Which rejections reach the fallback. Defaults to QuicPeekFallbackPolicy::NOT_QUIC.

Trait Implementations

impl<K, S, F> Clone for PeekQuicClientHelloService<K, S, F>

where K: Clone, S: Clone, F: Clone,

fn clone(&self) -> PeekQuicClientHelloService<K, S, F>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<K, S, F> Debug for PeekQuicClientHelloService<K, S, F>

where K: Debug, S: Debug, F: Debug,

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

Formats the value using the given formatter.

impl<I, K, S, F, O> Service<I> for PeekQuicClientHelloService<K, S, F>

where I: DatagramPeekInput, <I as DatagramPeekInput>::Mapped<PrefixedDatagramSocket<<I as DatagramPeekInput>::Socket>>: ExtensionsRef, K: KeyProvider + Send + Sync + 'static, S: Service<InputWithQuicClientHello<<I as DatagramPeekInput>::Mapped<PrefixedDatagramSocket<<I as DatagramPeekInput>::Socket>>>, Output = O>, <S as Service<InputWithQuicClientHello<<I as DatagramPeekInput>::Mapped<PrefixedDatagramSocket<<I as DatagramPeekInput>::Socket>>>>>::Error: Into<Box<dyn Error + Send + Sync>>, F: Service<<I as DatagramPeekInput>::Mapped<PrefixedDatagramSocket<<I as DatagramPeekInput>::Socket>>, Output = O>, <F as Service<<I as DatagramPeekInput>::Mapped<PrefixedDatagramSocket<<I as DatagramPeekInput>::Socket>>>>::Error: Into<Box<dyn Error + Send + Sync>>, O: Send + 'static,

type Output = O

The type of the output returned by the service.

type Error = Box<dyn Error + Send + Sync>

The type of error returned by the service.

fn serve( &self, input: I, ) -> impl Future<Output = Result<O, Box<dyn Error + Send + Sync>>> + Send

Serve an output or an error for the given input

fn boxed(self) -> BoxService<Input, Self::Output, Self::Error>

Box this service to allow for dynamic dispatch.