Struct HttpUpgradeMitmRelay 

pub struct HttpUpgradeMitmRelay<M, S> { /* private fields */ }

Available on crate features http and std only.

Http middleware that can be used by MITM proxies, such as transparent (L4) proxies to relay a HTTP upgrade-request as-is and pipe the upgraded upgrade request on both ends via the upgrade (bridgeIo) svc.

Matchers and response middleware select protocol metadata with HttpUpgradeMitmRelayExtensions. Request selections reach the ingress transport and response selections reach the egress transport, after both upgrades succeed. Each upgraded transport otherwise retains its own connection or HTTP/2 stream state.

See HttpUpgradeMitmRelayExtensions for an example of selecting metadata.

Implementations

impl<M, S> HttpUpgradeMitmRelay<M, S>

pub fn new( exec: Executor, nested_matcher_svc: M, inner_svc: S, ) -> HttpUpgradeMitmRelay<M, S>

Create a new HttpUpgradeMitmRelay.

pub fn with_error_sink(self, sink: impl ErrorSink) -> HttpUpgradeMitmRelay<M, S>

Set a custom ErrorSink used to observe errors from the detached relay task (relay-service failures and upgrade failures on either side).

Defaults to TracingErrorSink::default (traces at DEBUG level).

Trait Implementations

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

where M: Clone, S: Clone,

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

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

where M: Debug, S: Debug,

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

Formats the value using the given formatter.

impl<M, S, ReqBody, ModReqBody, ResBody, ModResBody> Service<Request<ReqBody>> for HttpUpgradeMitmRelay<M, S>

where <M as ServiceMatcher<Request<ReqBody>>>::Error: IntoResponse, <M as ServiceMatcher<Request<ReqBody>>>::Service: ServiceMatcher<Response<ResBody>, ModifiedInput = Response<ModResBody>>, <<M as ServiceMatcher<Request<ReqBody>>>::Service as ServiceMatcher<Response<ResBody>>>::Error: Into<<S as Service<Request>>::Error>, <<M as ServiceMatcher<Request<ReqBody>>>::Service as ServiceMatcher<Response<ResBody>>>::Service: Service<BridgeIo<Upgraded, Upgraded>>, <<<M as ServiceMatcher<Request<ReqBody>>>::Service as ServiceMatcher<Response<ResBody>>>::Service as Service<BridgeIo<Upgraded, Upgraded>>>::Error: Into<Box<dyn Error + Send + Sync>>, S: Service<Request, Output = Response<ResBody>>, ReqBody: Body<Data = Bytes> + Send + Sync + 'static, <ReqBody as Body>::Error: Into<Box<dyn Error + Send + Sync>>, ModReqBody: Body<Data = Bytes> + Send + Sync + 'static, <ModReqBody as Body>::Error: Into<Box<dyn Error + Send + Sync>>, ResBody: Body<Data = Bytes> + Send + Sync + 'static, <ResBody as Body>::Error: Into<Box<dyn Error + Send + Sync>>, ModResBody: Body<Data = Bytes> + Send + Sync + 'static, M: ServiceMatcher<Request<ReqBody>, ModifiedInput = Request<ModReqBody>>, <ModResBody as Body>::Error: Into<Box<dyn Error + Send + Sync>>,

type Output = Response

The type of the output returned by the service.

type Error = <S as Service<Request>>::Error

The type of error returned by the service.

async fn serve( &self, req: Request<ReqBody>, ) -> Result<<HttpUpgradeMitmRelay<M, S> as Service<Request<ReqBody>>>::Output, <HttpUpgradeMitmRelay<M, S> as Service<Request<ReqBody>>>::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.