support proxy (karmada-io#307)

Signed-off-by: liufen90 <[email protected]>

Author: liufen90

pkg/karmadactl/join.go

@@ -266,6 +266,15 @@ func RunJoin(cmdOut io.Writer, karmadaConfig KarmadaConfig, opts CommandJoinOpti
 		clusterObj.Spec.InsecureSkipTLSVerification = true
 	}
 
+	if clusterConfig.Proxy != nil {
+		url, err := clusterConfig.Proxy(nil)
+		if err != nil {
+			klog.Errorf("clusterConfig.Proxy error, %v", err)
+			return err
+		}
+		clusterObj.Spec.ProxyURL = url.String()
+	}
+
 	cluster, err := CreateClusterObject(controlPlaneKarmadaClient, clusterObj, false)
 	if err != nil {
 		klog.Errorf("failed to create cluster object. cluster name: %s, error: %v", opts.ClusterName, err)

pkg/util/membercluster_client.go

@@ -3,13 +3,16 @@ package util
 import (
 	"context"
 	"fmt"
+	"net/http"
+	"net/url"
 
 	v1 "k8s.io/api/core/v1"
 	"k8s.io/apimachinery/pkg/types"
 	"k8s.io/client-go/dynamic"
 	kubeclientset "k8s.io/client-go/kubernetes"
 	"k8s.io/client-go/rest"
 	"k8s.io/client-go/tools/clientcmd"
+	"k8s.io/klog/v2"
 	controllerruntime "sigs.k8s.io/controller-runtime"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 
@@ -131,5 +134,14 @@ func buildClusterConfig(cluster *v1alpha1.Cluster, client client.Client) (*rest.
 		clusterConfig.CAData = secret.Data[cADataKey]
 	}
 
+	if cluster.Spec.ProxyURL != "" {
+		proxy, err := url.Parse(cluster.Spec.ProxyURL)
+		if err != nil {
+			klog.Errorf("parse proxy error. %v", err)
+			return nil, err
+		}
+		clusterConfig.Proxy = http.ProxyURL(proxy)
+	}
+
 	return clusterConfig, nil
 }