From 2f3ac7dc7944030d43307ad738cdaaf97900e1c7 Mon Sep 17 00:00:00 2001 From: Amir Alavi Date: Mon, 6 May 2024 18:48:24 -0400 Subject: [PATCH] chore: reuse proxyutil import for proxy Signed-off-by: Amir Alavi --- pkg/util/proxy/proxy.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/pkg/util/proxy/proxy.go b/pkg/util/proxy/proxy.go index 64ffef139..3e75108fb 100644 --- a/pkg/util/proxy/proxy.go +++ b/pkg/util/proxy/proxy.go @@ -32,7 +32,6 @@ import ( corev1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/util/httpstream" utilnet "k8s.io/apimachinery/pkg/util/net" - "k8s.io/apimachinery/pkg/util/proxy" proxyutil "k8s.io/apimachinery/pkg/util/proxy" "k8s.io/apiserver/pkg/authentication/user" "k8s.io/apiserver/pkg/endpoints/handlers/responsewriters" @@ -119,8 +118,8 @@ func newProxyHandler(location *url.URL, proxyTransport http.RoundTripper, cluste // NewThrottledUpgradeAwareProxyHandler creates a new proxy handler with a default flush interval. Responder is required for returning // errors to the caller. -func NewThrottledUpgradeAwareProxyHandler(location *url.URL, transport http.RoundTripper, wrapTransport, upgradeRequired bool, responder registryrest.Responder) *proxy.UpgradeAwareHandler { - return proxy.NewUpgradeAwareHandler(location, transport, wrapTransport, upgradeRequired, proxy.NewErrorResponder(responder)) +func NewThrottledUpgradeAwareProxyHandler(location *url.URL, transport http.RoundTripper, wrapTransport, upgradeRequired bool, responder registryrest.Responder) *proxyutil.UpgradeAwareHandler { + return proxyutil.NewUpgradeAwareHandler(location, transport, wrapTransport, upgradeRequired, proxyutil.NewErrorResponder(responder)) } // GetTLSConfigForCluster returns a tls config for the cluster.