feat(io): TokioIo<T>: PeerAddr

Signed-off-by: katelyn martin <[email protected]>
linkerd · Mar 11, 2025 · f5dae03 · f5dae03
1 parent ed42c2a
commit f5dae03
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 0 deletions.
diff --git a/Cargo.lock b/Cargo.lock
@@ -1938,6 +1938,7 @@ dependencies = [
  "async-trait",
  "bytes",
  "futures",
+ "hyper-util",
  "linkerd-errno",
  "pin-project",
  "tokio",

diff --git a/linkerd/io/Cargo.toml b/linkerd/io/Cargo.toml
@@ -16,6 +16,7 @@ default = []
 async-trait = "0.1"
 futures = { version = "0.3", default-features = false }
 bytes = { workspace = true }
+hyper-util = { workspace = true, features = ["tokio"] }
 linkerd-errno = { path = "../errno" }
 tokio = { version = "1", features = ["io-util", "net"] }
 tokio-test = { version = "0.4", optional = true }

diff --git a/linkerd/io/src/lib.rs b/linkerd/io/src/lib.rs
@@ -76,3 +76,10 @@ impl PeerAddr for tokio::io::DuplexStream {
         Ok(([0, 0, 0, 0], 0).into())
     }
 }
+
+impl<T: PeerAddr> PeerAddr for hyper_util::rt::tokio::TokioIo<T> {
+    #[inline]
+    fn peer_addr(&self) -> Result<SocketAddr> {
+        self.inner().peer_addr()
+    }
+}