Function RegisterAgentCommand

cli/ctl/agent.go:47–131

()

var isDebug, isAggIP bool

func RegisterAgentCommand() *cobra.Command {
	agent := &cobra.Command{
		Use:   "agent",
		Short: "agent operation commands",
		Run: func(cmd *cobra.Command, args []string) {
			fmt.Printf("please run with 'list'.\n")
		},
	}

	var listOutput string
	list := &cobra.Command{
		Use:     "list [name]",
		Short:   "list agent info",
		Example: "deepflow-ctl agent list deepflow-agent -o yaml",
		Run: func(cmd *cobra.Command, args []string) {
			listAgent(cmd, args, listOutput)
		},
	}
	list.Flags().StringVarP(&listOutput, "output", "o", "", "output format")

	delete := &cobra.Command{
		Use:     "delete [name]",
		Short:   "delete agent",
		Example: "deepflow-ctl agent delete deepflow-agent",
		Run: func(cmd *cobra.Command, args []string) {
			deleteAgent(cmd, args)
		},
	}

	var updateFilename string
	update := &cobra.Command{
		Use:     "update -f <filename>",
		Short:   "update agent",
		Example: "deepflow-ctl agent update -f agent.yaml",
		Run: func(cmd *cobra.Command, args []string) {
			updateAgent(cmd, args, updateFilename)
		},
	}
	update.Flags().StringVarP(&updateFilename, "filename", "f", "", "file to use update agent")
	update.MarkFlagRequired("filename")

	updateExample := &cobra.Command{
		Use:     "update-example",
		Short:   "example agent update yaml",
		Example: "deepflow-ctl agent update-example",
		Run: func(cmd *cobra.Command, args []string) {
			fmt.Printf(string(example.YamlVtapUpdateConfig))
		},
	}

	var typeStr string

	rebalanceCmd := &cobra.Command{
		Use:   "rebalance",
		Short: "rebalance controller or analyzer",
		Example: `deepflow-ctl agent rebalance (rebalance controller and analyzer)
deepflow-ctl agent rebalance --type=controller
deepflow-ctl agent rebalance --type=analyzer`,