fix 修改 util Cluster 根据ClusterId 保存并读取kube config

wangpengfei

2023-06-08 2ad213b923c4475efe7d76dfdcbb8323616a6a3a

 src/main/main.go

@@ -188,15 +188,20 @@

   // 执行 create 命令
   if createCmd.Parsed() {

      // 配置 Kubernetes 集群的 kubeconfig 路径
      kubeconfig := flag.String("kubeconfig", filepath.Join(util.HomeDir(), ".kube", "config"), "kubeconfig file")
      flag.Parse()

      fmt.Println(&kubeconfig)

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

      fmt.Println(&config)

      clientset, err := kubernetes.NewForConfig(config)
      if err != nil {
@@ -209,7 +214,12 @@
         os.Exit(1)
      }

      err = k8s.CreateDeploymentAndService(clientset, *createNamespace, *createDeployment, *createService)
      err = k8s.CreateDeploymentAndService(k8s.Config{
         Client:         clientset,
         NameSpace:      *createNamespace,
         DeploymentName: *createDeployment,
         ServiceName:    *createService,
      })
      if err != nil {
         panic(err)
      }
@@ -277,7 +287,12 @@
      for _, ns := range namespaces {
         deploymentName := ns
         serviceName := ns
         err := k8s.CreateDeploymentAndService(clientset, ns, deploymentName, serviceName)
         err := k8s.CreateDeploymentAndService(k8s.Config{
            Client:         clientset,
            NameSpace:      ns,
            DeploymentName: deploymentName,
            ServiceName:    serviceName,
         })
         if err != nil {
            log.Printf("\033[97;41mFailed to create resources in namespace %s: %v\033[0m\n", ns, err)
         } else {