fix

wangpengfei

2023-06-05 94e73826a2c21e968804706b1955aea239220a1a

 src/util/util.go

@@ -3,9 +3,13 @@
import (
   "context"
   "crypto/tls"
   "flag"
   "fmt"
   "k8s.io/client-go/kubernetes"
   "k8s.io/client-go/tools/clientcmd"
   "net/http"
   "os"
   "path/filepath"
   "time"

   "golang.org/x/crypto/ssh"
@@ -145,3 +149,26 @@
   fmt.Println("kubectl has been installed on the remote server.")
   return nil
}

var kubeConfig *string

func GetClient() (*kubernetes.Clientset, error) {
   // 配置 Kubernetes 集群的 kubeconfig 路径
   if kubeConfig == nil {
      kubeConfig = flag.String("kubeconfig", filepath.Join(HomeDir(), ".kube", "config"), "kubeconfig file")
      flag.Parse()
   }

   // 创建 Kubernetes 客户端
   config, err := clientcmd.BuildConfigFromFlags("", *kubeConfig)
   if err != nil {
      panic(err.Error())
   }

   clientset, err := kubernetes.NewForConfig(config)
   if err != nil {
      panic(err.Error())
   }

   return clientset, nil
}