feat: add cluster subcommand for vsctl (#411)

Signed-off-by: jyjiangkai <[email protected]>

Author: hwjiangkai

vsctl/command/cluster.go

@@ -1,4 +1,4 @@
-// Copyright 2022 Linkall Inc.
+// Copyright 2023 Linkall Inc.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.

vsctl/command/connector.go

@@ -1,4 +1,4 @@
-// Copyright 2022 Linkall Inc.
+// Copyright 2023 Linkall Inc.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.

vsctl/command/event.go

@@ -1,4 +1,4 @@
-// Copyright 2022 Linkall Inc.
+// Copyright 2023 Linkall Inc.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -55,6 +55,22 @@ var (
 
 	showSegment bool
 	showBlock   bool
+
+	// for cluster
+	clusterVersion        string
+	controllerReplicas    int32
+	controllerStorageSize string
+	storeReplicas         int32
+	storeStorageSize      string
+	triggerReplicas       int32
+
+	// for connector
+	configfile       string
+	kind             string
+	name             string
+	ctype            string
+	connectorVersion string
+	showConnectors   bool
 )
 
 const (

vsctl/command/eventbus.go

@@ -1,4 +1,4 @@
-// Copyright 2022 Linkall Inc.
+// Copyright 2023 Linkall Inc.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -32,11 +32,17 @@ const (
 	FormatJSON = "json"
 )
 
+const (
+	HttpPrefix = "http://"
+	BaseUrl    = "/api/v1"
+)
+
 type GlobalFlags struct {
-	Endpoint   string
-	Debug      bool
-	ConfigFile string
-	Format     string
+	Endpoint         string
+	OperatorEndpoint string
+	Debug            bool
+	ConfigFile       string
+	Format           string
 }
 
 var (

vsctl/command/flag.go

@@ -1,4 +1,4 @@
-// Copyright 2022 Linkall Inc.
+// Copyright 2023 Linkall Inc.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.

vsctl/command/global.go

@@ -1,4 +1,4 @@
-// Copyright 2022 Linkall Inc.
+// Copyright 2023 Linkall Inc.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -15,8 +15,10 @@
 package command
 
 import (
+	"bytes"
 	"encoding/json"
 	"fmt"
+	"net/http"
 	"os"
 
 	"github.com/fatih/color"
@@ -55,3 +57,20 @@ func cmdFailedWithHelpNotice(cmd *cobra.Command, format string) {
 	_ = cmd.Help()
 	os.Exit(-1)
 }
+
+func operatorIsDeployed(cmd *cobra.Command, endpoint string) bool {
+	client := &http.Client{}
+	url := fmt.Sprintf("http://%s/api/v1/vanus/healthz", endpoint)
+	req, err := http.NewRequest("GET", url, &bytes.Reader{})
+	if err != nil {
+		return false
+	}
+
+	req.Header.Set("Content-Type", "application/json")
+	resp, err := client.Do(req)
+	if err != nil {
+		return false
+	}
+	defer resp.Body.Close()
+	return true
+}

vsctl/command/meta.go

@@ -1,4 +1,4 @@
-// Copyright 2022 Linkall Inc.
+// Copyright 2023 Linkall Inc.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -42,6 +42,8 @@ func init() {
 	cobra.EnableCommandSorting = false
 	rootCmd.PersistentFlags().StringVar(&globalFlags.Endpoint, "endpoint",
 		"127.0.0.1:8080", "the endpoints of vanus controller")
+	rootCmd.PersistentFlags().StringVar(&globalFlags.OperatorEndpoint, "operator-endpoint",
+		"127.0.0.1:8080", "the endpoints of vanus operator")
 	rootCmd.PersistentFlags().StringVarP(&globalFlags.ConfigFile, "config", "C",
 		"~/.vanus/vanus.yml", "the config file of vsctl")
 	rootCmd.PersistentFlags().BoolVarP(&globalFlags.Debug, "debug", "D", false,
@@ -53,11 +55,16 @@ func init() {
 		globalFlags.Endpoint = os.Getenv("VANUS_GATEWAY")
 	}
 
+	if os.Getenv("VANUS_OPERATOR") != "" {
+		globalFlags.OperatorEndpoint = os.Getenv("VANUS_OPERATOR")
+	}
+
 	rootCmd.AddCommand(
 		command.NewEventCommand(),
 		command.NewEventbusCommand(),
 		command.NewSubscriptionCommand(),
 		command.NewClusterCommand(),
+		command.NewConnectorCommand(),
 		newVersionCommand(),
 	)
 	rootCmd.CompletionOptions.DisableDefaultCmd = true