Struct ConnectUdpConnector 

pub struct ConnectUdpConnector<S, C> { /* private fields */ }

Available on crate feature masque only.

A datagram proxy connector for MASQUE (RFC 9298): a request on a ProxyRoute to a MASQUE proxy gets a CONNECT-UDP tunnel to its target, opened with the HTTP client S; every other request goes to the inner datagram connector C.

The tunnel’s target keeps its name: the proxy resolves it. A request addressed to its own MASQUE proxy (ProxyRoute::addresses_proxy) goes to C, as does a request without a proxy route. A proxy route to any other kind of proxy is refused, so it is never bypassed. A tunnel publishes EstablishedProxyRoute::Tunnel on its socket.

S sends the CONNECT-UDP request to the proxy: it needs proxy support, so the proxy’s credentials go with it, and, for HTTP/3 datagrams, an outer initial MTU of OUTER_INITIAL_MTU.

Implementations

impl<S, C> ConnectUdpConnector<S, C>

pub fn new(inner: C, client: S, exec: Executor) -> ConnectUdpConnector<S, C>

Tunnel MASQUE routes with client and serve the rest with inner; exec runs each tunnel’s send task.

pub fn with_version(self, version: Version) -> ConnectUdpConnector<S, C>

The HTTP version of the CONNECT-UDP request to the proxy; HTTP/3 by default.

pub fn set_version( &mut self, version: Version, ) -> &mut ConnectUdpConnector<S, C>

The HTTP version of the CONNECT-UDP request to the proxy; HTTP/3 by default.

pub fn with_socket_config( self, config: ConnectUdpSocketConfig, ) -> ConnectUdpConnector<S, C>

Limits of each tunnel, including its idle timeout.

pub fn set_socket_config( &mut self, config: ConnectUdpSocketConfig, ) -> &mut ConnectUdpConnector<S, C>

Limits of each tunnel, including its idle timeout.

Trait Implementations

impl<S, C> Clone for ConnectUdpConnector<S, C>

where S: Clone, C: Clone,

fn clone(&self) -> ConnectUdpConnector<S, C>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S, C> Debug for ConnectUdpConnector<S, C>

where S: Debug, C: Debug,

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

Formats the value using the given formatter.

impl<S, C> Service<ConnectRequest> for ConnectUdpConnector<S, C>

where S: Service<Request, Output = Response>, <S as Service<Request>>::Error: Into<Box<dyn Error + Send + Sync>>, C: ConnectorService<ConnectRequest>, <C as ConnectorService<ConnectRequest>>::Connection: DatagramSocket,

type Output = EstablishedClientConnection<MaybeTunneledSocket<<C as ConnectorService<ConnectRequest>>::Connection>, ConnectRequest>

The type of the output returned by the service.

type Error = ConnectionError

The type of error returned by the service.

async fn serve( &self, input: ConnectRequest, ) -> Result<<ConnectUdpConnector<S, C> as Service<ConnectRequest>>::Output, <ConnectUdpConnector<S, C> as Service<ConnectRequest>>::Error>

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.