FEATURE: Add foundation for zk and cluster management

Author: f1v3-dev

.github/workflows/ci.yml

@@ -12,7 +12,7 @@ jobs:
       - name: Set up Go
         uses: actions/setup-go@v5
         with:
-          go-version: '1.24.6'
+          go-version: '1.25.0'
       - name: Cache Go modules
         uses: actions/cache@v4
         with:

cmd/cluster/cluster.go

@@ -0,0 +1,17 @@
+package cluster
+
+import "github.com/spf13/cobra"
+
+var ClusterCmd = &cobra.Command{
+	Use:   "cluster",
+	Short: "Manage Arcus clusters",
+}
+
+func init() {
+	ClusterCmd.AddCommand(deployCmd)
+	ClusterCmd.AddCommand(startCmd)
+	ClusterCmd.AddCommand(stopCmd)
+	ClusterCmd.AddCommand(deleteCmd)
+	ClusterCmd.AddCommand(listCmd)
+	ClusterCmd.AddCommand(statusCmd)
+}

cmd/cluster/delete.go

@@ -0,0 +1,12 @@
+package cluster
+
+import "github.com/spf13/cobra"
+
+var deleteCmd = &cobra.Command{
+	Use:   "delete <servicecode>",
+	Short: "Delete an Arcus cluster",
+	Args:  cobra.ExactArgs(1),
+	Run: func(cmd *cobra.Command, args []string) {
+		// TODO: delete 구현
+	},
+}

cmd/cluster/deploy.go

@@ -0,0 +1,12 @@
+package cluster
+
+import "github.com/spf13/cobra"
+
+var deployCmd = &cobra.Command{
+	Use:   "deploy <version> <topology.yml>",
+	Short: "Deploy a new Arcus cluster",
+	Args:  cobra.ExactArgs(2),
+	Run: func(cmd *cobra.Command, args []string) {
+		// TODO: deploy 구현
+	},
+}

cmd/cluster/list.go

@@ -0,0 +1,12 @@
+package cluster
+
+import "github.com/spf13/cobra"
+
+var listCmd = &cobra.Command{
+	Use:   "list",
+	Short: "List managed Arcus clusters",
+	Args:  cobra.NoArgs,
+	Run: func(cmd *cobra.Command, args []string) {
+		// TODO: list 구현
+	},
+}

cmd/cluster/start.go

@@ -0,0 +1,16 @@
+package cluster
+
+import "github.com/spf13/cobra"
+
+var startCmd = &cobra.Command{
+	Use:   "start <servicecode> [--node <address>]",
+	Short: "Start an Arcus cluster",
+	Args:  cobra.ExactArgs(1),
+	Run: func(cmd *cobra.Command, args []string) {
+		// TODO: start 구현
+	},
+}
+
+func init() {
+	startCmd.Flags().String("node", "", "address of the specific node to start")
+}

cmd/cluster/status.go

@@ -0,0 +1,12 @@
+package cluster
+
+import "github.com/spf13/cobra"
+
+var statusCmd = &cobra.Command{
+	Use:   "status <servicecode>",
+	Short: "Show status of an Arcus cluster",
+	Args:  cobra.ExactArgs(1),
+	Run: func(cmd *cobra.Command, args []string) {
+		// TODO: status 구현
+	},
+}

cmd/cluster/stop.go

@@ -0,0 +1,16 @@
+package cluster
+
+import "github.com/spf13/cobra"
+
+var stopCmd = &cobra.Command{
+	Use:   "stop <servicecode> [--node <address>]",
+	Short: "Stop an Arcus cluster",
+	Args:  cobra.ExactArgs(1),
+	Run: func(cmd *cobra.Command, args []string) {
+		// TODO: stop 구현
+	},
+}
+
+func init() {
+	stopCmd.Flags().String("node", "", "address of the specific node to stop")
+}

cmd/connect.go

@@ -38,7 +38,7 @@ credentials are provided, SASL SCRAM-SHA-256 authentication will be performed.`,
 		if err != nil {
 			panic(err)
 		}
-		defer conn.Close()
+		defer func() { _ = conn.Close() }()
 
 		if len(args) == 2 {
 			username, password, _ := strings.Cut(args[1], ":")

cmd/root.go

@@ -6,6 +6,8 @@ import (
 	"runtime/debug"
 
 	"github.com/jam2in/arcusctl/cmd/acl"
+	"github.com/jam2in/arcusctl/cmd/cluster"
+	"github.com/jam2in/arcusctl/cmd/zk"
 	"github.com/jam2in/arcusctl/internal"
 	"github.com/spf13/cobra"
 )
@@ -35,6 +37,8 @@ func init() {
 	rootCmd.AddCommand(versionCmd)
 	rootCmd.AddCommand(acl.RootCmd)
 	rootCmd.AddCommand(connectCmd)
+	rootCmd.AddCommand(zk.ZKCmd)
+	rootCmd.AddCommand(cluster.ClusterCmd)
 
 	cobra.OnInitialize(internal.InitConfig)
 }