更新代码

cheliequan

2023-05-24 ab70148fc0213a4523d976099a18e438cb2ed067

 src/cluster/cluster.go

@@ -1,16 +1,14 @@
package cluster

import (
   "_/E_/git/aps_deploy/src/util"
   "bytes"
   "encoding/json"
   "fmt"
   "log"
   "net/http"
   "os"
   "strings"

   "../util"
   "basic.com/aps/aps_deploy.git/src/util"
)

type Cluster struct {
@@ -200,7 +198,7 @@

// Deploy Kubernetes roles on a node using SSH
func Deployk8sRolesOnNode(nodeIP, sshUsername, sshPassword, remoteSSHCommand string, sshPort int, roles []string) error {
   rancherAgentInstalled, err := isRancherAgentInstalled(nodeIP, sshUsername, sshPassword, sshPort)
   rancherAgentInstalled, err := IsRancherAgentInstalled(nodeIP, sshUsername, sshPassword, sshPort)
   if err == nil {
      return nil
   }
@@ -220,18 +218,18 @@
         }
      }

      _, err := sshExec(nodeIP, sshUsername, sshPassword, remoteSSHCommand, sshPort)
      _, err := util.SSHExec(nodeIP, sshUsername, sshPassword, remoteSSHCommand, sshPort)
      if err != nil {
         return fmt.Errorf("failed to deploy Kubernetes roles on the remote server: %v", err)
      }
      return nil
   }
   return nil
}

func IsRancherInstalled(ip, username, password string, sshPort int) (bool, error) {
   // 检查Rancher容器是否已运行
   checkRancherCommand := "sudo docker ps --format '{{.Image}}' | grep -q rancher/rancher:v2.5.17"
   _, err := sshExec(ip, username, password, checkRancherCommand, sshPort)
   _, err := util.SSHExec(ip, username, password, checkRancherCommand, sshPort)
   if err != nil {
      // 如果执行命令出错，则说明Rancher未安装或发生其他错误
      return false, fmt.Errorf("failed to check Rancher installation: %v", err)
@@ -243,7 +241,7 @@
func IsRancherAgentInstalled(ip, username, password string, sshPort int) (bool, error) {
   // 检查Rancher容器是否已运行
   checkRancherCommand := "sudo docker ps --format '{{.Image}}' | grep -q rancher/rancher-agent:v2.5."
   _, err := sshExec(ip, username, password, checkRancherCommand, sshPort)
   _, err := util.SSHExec(ip, username, password, checkRancherCommand, sshPort)
   if err != nil {
      // 如果执行命令出错，则说明Rancher未安装或发生其他错误
      return false, fmt.Errorf("failed to check Rancher installation: %v", err)
@@ -285,91 +283,4 @@
   fmt.Printf("Cluster created: ID=%s, Name=%s\n", responseBody.ID, responseBody.Name)

   return nil
}

func main() {
   clusterName := "kubernetus"
   nodes := []Node{
      {
         ClusterName: clusterName,
         Roles:       []string{"etcd", "controlplane", "worker"},
         IP:          "192.168.20.189",
         SSHUsername: "basic",
         SSHPassword: "123",
         SSHPort:     22,
      },
      {
         ClusterName: clusterName,
         Roles:       []string{"worker"},
         IP:          "192.168.20.10",
         SSHUsername: "basic",
         SSHPassword: "123",
         SSHPort:     22,
      },
      {
         ClusterName: clusterName,
         Roles:       []string{"worker"},
         IP:          "192.168.20.115",
         SSHUsername: "basic",
         SSHPassword: "alien123",
         SSHPort:     22,
      },
      // Add more nodes here if needed
   }

   // Create the cluster
   // Rancher configuration
   /*rancherConfig := RancherConfig{
      RancherURL:  "https://192.168.20.119:8443",
      BearerToken: "token-nnrsc:w68zdt8s47fnpjd5xqdl5hhzpz4j2d56kt5nx49nsswcbpdzc28kh5",
   }*/

   rancherConfig := RancherConfig{
      RancherURL:  "https://192.168.20.189:8443",
      BearerToken: "token-t4cdf:h7zhmbvbzdvd9mmjw8zmt8rh4m7rl5gtqpqljlhl9tlr2z26j9lf4l",
   }

   //   Deploy clusterId
   clusterID, err := GetClusterID(rancherConfig.RancherURL, rancherConfig.BearerToken, clusterName)
   if err != nil {
      log.Fatal(err)
      err = CreateCluster(rancherConfig, clusterName)
      if err != nil {
         log.Fatalf("Failed to create cluster: %v", err)
      }
      fmt.Printf("Cluster created: %s\n", clusterName)
      clusterID, err = GetClusterID(rancherConfig.RancherURL, rancherConfig.BearerToken, clusterName)
      if err != nil {
         log.Fatal(err)
      }
   }
   fmt.Println(clusterID)

   //   Deploy nodeCommand
   nodeCommand, err := GetNodeCommand(rancherConfig.RancherURL, rancherConfig.BearerToken, clusterID)
   if err != nil {
      log.Fatal(err)
   }
   fmt.Println(nodeCommand)

   for _, node := range nodes {
      //Deploy Docker on each node
      err = util.InstallDocker(node.IP, node.SSHUsername, node.SSHPassword, node.SSHPort)
      if err != nil {
         log.Fatal(err)
      }

      // Deploy Kubectl on each node
      err = util.InstallKubectl(node.IP, node.SSHUsername, node.SSHPassword, node.SSHPort)
      if err != nil {
         log.Fatal(err)
      }

      // Deploy Kubernetes roles on each node
      err = Deployk8sRolesOnNode(node.IP, node.SSHUsername, node.SSHPassword, nodeCommand, node.SSHPort, node.Roles)
      if err != nil {
         log.Fatal(err)
      }
   }
   os.Exit(0)
}