fix

wangpengfei

2023-06-08 794b44835f98df719f2b1186b2ad90a11f9a35b0

 src/cluster/cluster.go

@@ -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
}