From 68c007e836384635d843bbc61174fae5b09ccd1c Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期六, 06 一月 2024 17:08:07 +0800
Subject: [PATCH] 增加对crm,wms,srm的部署支持
---
src/main/main.go | 80 ++++++++++++++++++++++++---------------
1 files changed, 49 insertions(+), 31 deletions(-)
diff --git a/src/main/main.go b/src/main/main.go
index 530cf63..41dfb85 100644
--- a/src/main/main.go
+++ b/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{
- Client: clientset,
- NameSpace: *createNamespace,
- DeploymentName: *createDeployment,
- ServiceName: *createService,
- }, nil)
+ 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: 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)
- if err != nil {
- panic(err)
+ 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,23 +301,27 @@
for _, ns := range namespaces {
deploymentName := ns
serviceName := ns
- err := k8s.CreateDeploymentAndService(k8s.Config{
- Client: clientset,
- NameSpace: ns,
- DeploymentName: deploymentName,
- ServiceName: serviceName,
- }, nil)
- if err != nil {
- log.Printf("\033[97;41mFailed to create resources in namespace %s: %v\033[0m\n", ns, err)
- } else {
- nodeport, err := k8s.GetServiceNodePort(clientset, ns, ns)
+ for _, proj := range k8s.Projects {
+ obj := k8s.GetCreateObj(proj)
+ err = obj.CreateDeploymentAndService(k8s.Config{
+ Client: clientset,
+ NameSpace: ns,
+ DeploymentName: deploymentName,
+ ServiceName: serviceName,
+ }, nil)
if err != nil {
- panic(err)
- }
+ log.Printf("\033[97;41mFailed to create resources in namespace %s: %v\033[0m\n", ns, err)
+ } else {
+ nodeport, err := k8s.GetServiceNodePort(clientset, ns, ns)
+ if err != nil {
+ panic(err)
+ }
- log.Printf("Service NodePort: %d\n", nodeport)
- log.Printf("\033[97;42mSuccessfully created resources in namespace %s\033[0m\n", ns)
+ log.Printf("Service NodePort: %d\n", nodeport)
+ log.Printf("\033[97;42mSuccessfully created resources in namespace %s\033[0m\n", ns)
+ }
}
+
}
// 寤惰繜 1000 绉掑悗鍒犻櫎鍒涘缓鐨勮祫婧�
--
Gitblit v1.8.0