From 794b44835f98df719f2b1186b2ad90a11f9a35b0 Mon Sep 17 00:00:00 2001
From: wangpengfei <274878379@qq.com>
Date: 星期四, 08 六月 2023 20:28:11 +0800
Subject: [PATCH] fix
---
src/cluster/cluster.go | 17 ++++++++++-------
1 files changed, 10 insertions(+), 7 deletions(-)
diff --git a/src/cluster/cluster.go b/src/cluster/cluster.go
index 3af2437..1012b5b 100644
--- a/src/cluster/cluster.go
+++ b/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
}
--
Gitblit v1.8.0