NodePool Jobs

apps/nodectrl/Taskfile.yml

@@ -4,12 +4,18 @@ dotenv:
   - .secrets/env
 
 tasks:
+  gen-sec:
+    sources:
+      - ./internal/**/*.go
+      - ./main.go
+    cmds:
+      - cd ./.secrets && go run main.go
+
   run:
     sources:
       - ./internal/**/*.go
       - ./main.go
     cmds:
-      # - go run -tags dynamic main.go --dev
       - nodemon -e go --signal SIGKILL --exec 'go run  main.go --dev || exit 1'
 
   docker-build:

apps/nodectrl/internal/app/main.go

@@ -5,6 +5,7 @@ import (
 	"fmt"
 
 	"go.uber.org/fx"
+
 	"kloudlite.io/apps/nodectrl/internal/domain"
 	"kloudlite.io/apps/nodectrl/internal/domain/common"
 	"kloudlite.io/apps/nodectrl/internal/domain/utils"
@@ -17,21 +18,31 @@ var Module = fx.Module("app",
 		func(env *env.Env, pc common.ProviderClient, shutdowner fx.Shutdowner, lifecycle fx.Lifecycle) {
 			lifecycle.Append(fx.Hook{
 				OnStart: func(context.Context) error {
-
-					go func() error {
+					runner := func() error {
 						ctx := context.Background()
 						if err := utils.SetupGetWorkDir(); err != nil {
 							return err
 						}
 
 						err := func() error {
 							switch env.Action {
-							case "create":
-
+							case "create-cluster":
 								fmt.Println("needs to create node")
-								if err := pc.NewNode(ctx); err != nil {
+								if err := pc.CreateCluster(ctx); err != nil {
+									return err
+								}
+							case "add-master":
+								fmt.Println("needs to attach master")
+								if err := pc.AddMaster(ctx); err != nil {
+									return err
+								}
+
+							case "add-worker":
+								fmt.Println("needs to attach worker")
+								if err := pc.AddWorker(ctx); err != nil {
 									return err
 								}
+
 							case "delete":
 								fmt.Println("needs to delete node")
 								if err := pc.DeleteNode(ctx); err != nil {
@@ -48,12 +59,17 @@ var Module = fx.Module("app",
 							shutdowner.Shutdown()
 							return nil
 						}()
-
 						if err != nil {
 							fmt.Println(utils.ColorText(fmt.Sprint("\n", "Error: ", err, "\n"), 1))
 							return err
 						}
 						return nil
+					}
+
+					go func() {
+						if err := runner(); err != nil {
+							shutdowner.Shutdown()
+						}
 					}()
 
 					return nil
@@ -62,7 +78,6 @@ var Module = fx.Module("app",
 					return nil
 				},
 			})
-
 		},
 	),
 )