Merge pull request #96 from ferryproxy/fix/cloud

Fix cloud

Author: wzshiming

pkg/ferry-controller/controller/mapping/mapping_controller.go

@@ -89,6 +89,9 @@ type MappingController struct {
 }
 
 func (d *MappingController) Start(ctx context.Context) error {
+	d.mut.Lock()
+	defer d.mut.Unlock()
+
 	d.logger.Info("DataPlane controller started")
 	defer func() {
 		d.logger.Info("DataPlane controller stopped")

pkg/ferryctl/kubectl/kubectl.go

@@ -168,17 +168,23 @@ func (c *Kubectl) GetSecretAuthorized(ctx context.Context) (string, error) {
 }
 
 func (c *Kubectl) GetApiserverAddress(ctx context.Context) (string, error) {
-	out, err := commandRun(ctx, "kubectl", "--kubeconfig="+vars.KubeconfigPath, "get", "cm", "-n", "kube-public", "cluster-info", "-o", "jsonpath={$.data.kubeconfig}")
-	if err != nil {
-		return "", err
-	}
 	take := struct {
 		Clusters []struct {
 			Cluster struct {
 				Server string `yaml:"server"`
 			} `yaml:"cluster"`
 		} `yaml:"clusters"`
 	}{}
+
+	out, err := commandRun(ctx, "kubectl", "--kubeconfig="+vars.KubeconfigPath, "get", "cm", "-n", "kube-public", "cluster-info", "-o", "jsonpath={$.data.kubeconfig}")
+	if err != nil {
+		data, err := os.ReadFile(vars.KubeconfigPath)
+		if err != nil {
+			return "", err
+		}
+		out = data
+	}
+
 	err = yaml.Unmarshal(out, &take)
 	if err != nil {
 		return "", err