From 72be0de2b7f98db64dadfdd72b012b96f14d29b5 Mon Sep 17 00:00:00 2001
From: Javier Viola <363911+pepoviola@users.noreply.github.com>
Date: Tue, 16 Jul 2024 14:18:22 +0200
Subject: [PATCH] feat(k8s): add tracing for port-fwd (#239)
---
crates/provider/src/kubernetes/client.rs | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/crates/provider/src/kubernetes/client.rs b/crates/provider/src/kubernetes/client.rs
index 9d14dfc..d821c3d 100644
--- a/crates/provider/src/kubernetes/client.rs
+++ b/crates/provider/src/kubernetes/client.rs
@@ -393,10 +393,13 @@ impl KubernetesClient {
tokio::spawn(async move {
loop {
let (mut client_conn, _) = bind.accept().await.unwrap();
+ let peer = client_conn.peer_addr().unwrap();
+ trace!("new connection on local_port: {local_port}, peer: {peer}");
let (name, pods) = (name.clone(), pods.clone());
tokio::spawn(async move {
let mut forwarder = pods.portforward(&name, &[remote_port]).await.unwrap();
+ trace!("forwarder created for local_port: {local_port}, peer: {peer}");
let mut upstream_conn = forwarder.take_stream(remote_port).unwrap();
tokio::io::copy_bidirectional(&mut client_conn, &mut upstream_conn)
@@ -406,6 +409,9 @@ impl KubernetesClient {
drop(upstream_conn);
forwarder.join().await.unwrap();
+ trace!(
+ "finished forwarder process for local port: {local_port}, peer: {peer}"
+ );
});
}
}),
--
GitLab