Add proxy to validate rest config

rancher · Sep 27, 2022 · 7a0853f · 7a0853f
1 parent 6a89e30
commit 7a0853f
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pkg/k8splan/watcher.go b/pkg/k8splan/watcher.go
@@ -386,7 +386,8 @@ func validateKC(ctx context.Context, config *rest.Config) error {
 	}
 
 	config.Transport = utilnet.SetTransportDefaults(&http.Transport{
-		DialTLS: func(network, addr string) (net.Conn, error) {
+		Proxy: http.ProxyFromEnvironment,
+		DialTLSContext: func(_ context.Context, network, addr string) (net.Conn, error) {
 			conn, err = tls.Dial(network, addr, tlsConfig)
 			return conn, err
 		},
@@ -403,6 +404,7 @@ func validateKC(ctx context.Context, config *rest.Config) error {
 	if config.UserAgent == "" {
 		config.UserAgent = rest.DefaultKubernetesUserAgent()
 	}
+
 	rest, err := rest.UnversionedRESTClientFor(config)
 	if err != nil {
 		return err