增加admin_grpc环境变量

zhangqian

2024-01-12 fea217048591823280a888b6c26f68558e51dded

 src/cluster/cluster.go

@@ -236,7 +236,7 @@
   if err != nil {
      log.Fatalf("Failed to get home directory: %v", err)
   }
   kubeconfigDir := filepath.Join(homeDir, ".kube")
   kubeconfigDir := filepath.Join(homeDir, ".kube", clusterName)
   err = os.MkdirAll(kubeconfigDir, 0700)
   if err != nil {
      log.Fatalf("Failed to create .kube directory: %v", err)
@@ -350,14 +350,16 @@
   return true, nil
}

func CreateCluster(rancherClusterConfig rancher.RancherClusterConfig, clusterName string) error {
func CreateCluster(rancherClusterConfig rancher.RancherClusterConfig, clusterName string) (string, error) {
   requestBody := createClusterData(clusterName)
   fmt.Println(rancherClusterConfig.RancherURL)

   url := fmt.Sprintf("%s/v3/clusters", rancherClusterConfig.RancherURL)
   fmt.Println("url:    ", url)
   fmt.Println("body:    ", requestBody)
   req, err := http.NewRequest("POST", url, bytes.NewBuffer(requestBody))
   if err != nil {
      return fmt.Errorf("Failed to create HTTP request: %v", err)
      return "", fmt.Errorf("Failed to create HTTP request: %v", err)
   }

   req.Header.Set("Authorization", fmt.Sprintf("Bearer %s", rancherClusterConfig.BearerToken))
@@ -367,21 +369,22 @@

   resp, err := client.Do(req)
   if err != nil {
      return fmt.Errorf("Failed to send HTTP request: %v", err)
      return "", fmt.Errorf("Failed to send HTTP request: %v", err)
   }
   defer resp.Body.Close()

   if resp.StatusCode != http.StatusCreated {
      return fmt.Errorf("Failed to create cluster, status code: %d", resp.StatusCode)
      fmt.Println("1111111111111111111111111111    ", resp)
      return "", fmt.Errorf("Failed to create cluster, status code: %d", resp.StatusCode)
   }

   var responseBody ClusterCreateResponse
   err = json.NewDecoder(resp.Body).Decode(&responseBody)
   if err != nil {
      return fmt.Errorf("Failed to decode response body: %v", err)
      return "", fmt.Errorf("Failed to decode response body: %v", err)
   }

   fmt.Printf("Cluster created: ID=%s, Name=%s\n", responseBody.ID, responseBody.Name)

   return nil
   return responseBody.ID, nil
}