diff --git a/linkerd/app/inbound/src/direct.rs b/linkerd/app/inbound/src/direct.rs index f55b11e5c9..4927ccbb20 100644 --- a/linkerd/app/inbound/src/direct.rs +++ b/linkerd/app/inbound/src/direct.rs @@ -50,7 +50,7 @@ pub struct ClientInfo { type TlsIo = tls::server::Io>, I>; type FwdIo = SensorIo>>; -pub type GatewayIo = io::EitherIo, SensorIo>>; +pub type GatewayIo = FwdIo; #[derive(Clone)] struct TlsParams { @@ -167,7 +167,6 @@ impl Inbound { // HTTP detection is not necessary in this case, since the transport // header indicates the connection's HTTP version. svc::stack(gateway.clone()) - .push_on_service(svc::MapTargetLayer::new(io::EitherIo::Left)) .push(transport::metrics::NewServer::layer( rt.metrics.proxy.transport.clone(), ))