Struct ConnectUdpRelayRequestMatcher 

pub struct ConnectUdpRelayRequestMatcher<S = HttpDatagramRelay, M = bool> { /* private fields */ }

Available on crate feature masque only.

Select CONNECT-UDP upgrades for an HTTP/1.1 or HTTP/2 MITM relay.

Install in HttpUpgradeMitmRelayLayer, alongside WebSocket and CONNECT matchers. Refused responses pass through; malformed successful handshakes fail before upgrading. Use ConnectUdpMitmLayer for HTTP/3.

Implementations

impl ConnectUdpRelayRequestMatcher

pub fn default_with_exec(exec: Executor) -> ConnectUdpRelayRequestMatcher

Use bounded opaque forwarding with the supplied shutdown executor.

impl<S> ConnectUdpRelayRequestMatcher<S>

pub fn new(relay_svc: S) -> ConnectUdpRelayRequestMatcher<S>

Use a relay service, optionally decorated with ordinary Rama layers.

impl<S, M> ConnectUdpRelayRequestMatcher<S, M>

pub fn with_matcher<N>(self, matcher: N) -> ConnectUdpRelayRequestMatcher<S, N>

Select sessions by destination, headers or connection metadata. A non-match leaves the request to other handlers; it does not deny access. Use HTTP policy middleware to reject a request before forwarding it. Matcher metadata is attached to the request. To pass selected metadata to the relay service, use HTTP middleware to copy those values into the request’s own HttpUpgradeMitmRelayExtensions selection.

Trait Implementations

impl<S, M> Clone for ConnectUdpRelayRequestMatcher<S, M>

where S: Clone, M: Clone,

fn clone(&self) -> ConnectUdpRelayRequestMatcher<S, M>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S, M> Debug for ConnectUdpRelayRequestMatcher<S, M>

where S: Debug, M: Debug,

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

Formats the value using the given formatter.

impl Default for ConnectUdpRelayRequestMatcher

fn default() -> ConnectUdpRelayRequestMatcher

Returns the “default value” for a type.

impl<S, M, B> ServiceMatcher<Request<B>> for ConnectUdpRelayRequestMatcher<S, M>

where S: Clone + Send + Sync + 'static, M: Matcher<Request<B>>, B: Send + 'static,

type Service = ConnectUdpRelayResponseMatcher<S>

The value returned when a match succeeds.

type Error = !

The error that can happen while evaluating the matcher.

type ModifiedInput = Request<B>

Input returned by matching functions, it might be same as the original input but it can also be modified.

async fn match_service( &self, request: Request<B>, ) -> Result<ServiceMatch<Request<B>, <ConnectUdpRelayRequestMatcher<S, M> as ServiceMatcher<Request<B>>>::Service>, !>

Attempt to select a service for input.

fn into_match_service( self, input: Input, ) -> impl Future<Output = Result<ServiceMatch<Self::ModifiedInput, Self::Service>, Self::Error>> + Send

where Self: Sized, Input: Send,

Attempt to select a service for input, consuming the matcher.

fn boxed( self, ) -> BoxServiceMatcher<Input, Self::Service, Self::Error, Self::ModifiedInput>

where Self: Sized,

Box this matcher for dynamic dispatch.