From a3ad2aeffce3d88e5dc578fd08f39a54da9b3987 Mon Sep 17 00:00:00 2001 From: 7sunarni <710720732@qq.com> Date: Wed, 13 Nov 2024 15:45:18 +0800 Subject: [PATCH] feat(round-trip): add DebuggWrapper for http client Signed-off-by: 7sunarni <710720732@qq.com> --- cmd/adapter/adapter.go | 30 ++++++++++++++++++------------ 1 file changed, 18 insertions(+), 12 deletions(-) diff --git a/cmd/adapter/adapter.go b/cmd/adapter/adapter.go index f5c819a0..848ba350 100644 --- a/cmd/adapter/adapter.go +++ b/cmd/adapter/adapter.go @@ -393,7 +393,9 @@ func makeKubeconfigHTTPClient(inClusterAuth bool, kubeConfigPath string) (*http. // return the default client if we're using no auth if !inClusterAuth && kubeConfigPath == "" { - return http.DefaultClient, nil + return &http.Client{ + Transport: transport.DebugWrappers(http.DefaultTransport), + }, nil } var authConf *rest.Config @@ -436,23 +438,27 @@ func makePrometheusCAClient(caFilePath string, tlsCertFilePath string, tlsKeyFil return nil, fmt.Errorf("failed to read TLS key pair: %v", err) } return &http.Client{ - Transport: &http.Transport{ - TLSClientConfig: &tls.Config{ - RootCAs: pool, - Certificates: []tls.Certificate{tlsClientCerts}, - MinVersion: tls.VersionTLS12, + Transport: transport.DebugWrappers( + &http.Transport{ + TLSClientConfig: &tls.Config{ + RootCAs: pool, + Certificates: []tls.Certificate{tlsClientCerts}, + MinVersion: tls.VersionTLS12, + }, }, - }, + ), }, nil } return &http.Client{ - Transport: &http.Transport{ - TLSClientConfig: &tls.Config{ - RootCAs: pool, - MinVersion: tls.VersionTLS12, + Transport: transport.DebugWrappers( + &http.Transport{ + TLSClientConfig: &tls.Config{ + RootCAs: pool, + MinVersion: tls.VersionTLS12, + }, }, - }, + ), }, nil }