增加对crm,wms,srm的部署支持

zhangqian

2024-01-06 68c007e836384635d843bbc61174fae5b09ccd1c

 src/main/main.go

@@ -20,10 +20,10 @@
)

var (
   replicas      int32 = 3
   replicas      int32 = 1
   port          int32 = 9081
   usedNodePorts       = make(map[int32]bool)
   namespaces          = []string{"guangsheng", "geruimi", "tongsheng"}
   namespaces          = []string{"testFactory1", "testFactory2", "testFactory3"}
)

func rancher_install_test(node rancher.Node) {
@@ -127,8 +127,9 @@

   createNamespace := createCmd.String("ns", "", "Namespace name")
   createDeployment := createCmd.String("deployment", "", "Deployment name")
   fmt.Println(createDeployment)
   createService := createCmd.String("service", "", "Service name")

   fmt.Println(createService)
   deleteNamespace := deleteCmd.String("ns", "", "Namespace name")
   deleteDeployment := deleteCmd.String("deployment", "", "Deployment name")
   deleteService := deleteCmd.String("service", "", "Service name")
@@ -176,9 +177,9 @@
      rancherClusterConfig.Nodes = make([]rancher.Node, 3)
      rancherClusterConfig.Nodes[0] = rancher.Node{
         Roles:       []string{"worker"},
         IP:          "192.168.20.189",
         SSHUsername: "basic",
         SSHPassword: "123",
         IP:          "192.168.49.1",
         SSHUsername: "me",
         SSHPassword: "123456",
         SSHPort:     22,
      }

@@ -208,23 +209,31 @@
         panic(err.Error())
      }

      if *createNamespace == "" || *createDeployment == "" || *createService == "" {
      if *createNamespace == "" {
         fmt.Println("Namespace, Deployment, and Service names are required")
         createCmd.PrintDefaults()
         os.Exit(1)
      }

      err = k8s.CreateDeploymentAndService(k8s.Config{
      err = k8s.CreateNamespace(clientset, *createNamespace)
      if err != nil {
         panic(err)
      }
      for _, proj := range k8s.Projects {
         obj := k8s.GetCreateObj(proj)
         err = obj.CreateDeploymentAndService(k8s.Config{
         Client:         clientset,
         NameSpace:      *createNamespace,
         DeploymentName: *createDeployment,
         ServiceName:    *createService,
            DeploymentName: proj,
            ServiceName:    proj,
            Image:          "fai365.com:9088/aps/aps",
      }, nil)
      if err != nil {
         panic(err)
      }
      }

      nodeport, err := k8s.GetServiceNodePort(clientset, *createNamespace, *createService)
      nodeport, err := k8s.GetServiceNodePort(clientset, *createNamespace, "aps")
      if err != nil {
         panic(err)
      }
@@ -255,9 +264,14 @@
         os.Exit(1)
      }

      err = k8s.DeleteResources(clientset, *deleteNamespace, *deleteDeployment, *deleteService)
      for _, proj := range k8s.Projects {
         err = k8s.DeleteResources(clientset, *deleteNamespace, proj, proj)
      if err != nil {
         panic(err)
         }
         if err != nil {
            panic(err)
         }
      }

      fmt.Println("Resources deleted.")
@@ -287,7 +301,9 @@
      for _, ns := range namespaces {
         deploymentName := ns
         serviceName := ns
         err := k8s.CreateDeploymentAndService(k8s.Config{
         for _, proj := range k8s.Projects {
            obj := k8s.GetCreateObj(proj)
            err = obj.CreateDeploymentAndService(k8s.Config{
            Client:         clientset,
            NameSpace:      ns,
            DeploymentName: deploymentName,
@@ -306,6 +322,8 @@
         }
      }

      }

      // 延迟 1000 秒后删除创建的资源
      time.Sleep(1000 * time.Second)