Function RegisterPrometheusCommand

cli/ctl/prometheus.go:30–67

()

)

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

	var t string
	cacheCmd := &cobra.Command{
		Use:     "cache",
		Short:   "pull prometheus cache data from deepflow-server",
		Example: "deepflow-ctl prometheus cache -t metric-name",
		Run: func(cmd *cobra.Command, args []string) {
			if err := prometheusCache(cmd, t); err != nil {
				fmt.Println(err)
			}
		},
	}
	cacheCmd.Flags().StringVarP(&t, "type", "t", "all", "cache type, options: all, metric-name, label-name, "+
		"label-value, metric-and-app-layout, target, label, metric-label, metric-target")
	cmd.AddCommand(cacheCmd)

	var expiredAt string
	clearCmd := &cobra.Command{
		Use:     "clear",
		Short:   "clear prometheus data in MySQL by deepflow-server, use with caution and not frequently!",
		Example: "deepflow-ctl prometheus clear -e \"2006-01-02 15:04:05\"",
		Run: func(cmd *cobra.Command, args []string) {
			prometheusClear(cmd, expiredAt)
		},
	}
	clearCmd.Flags().StringVarP(&expiredAt, "expired-time", "e", "", "expired-time format: 2006-01-02 15:04:05")
	cmd.AddCommand(clearCmd)

	return cmd
}

func prometheusCache(cmd *cobra.Command, t string) error {
	conn := getConn(cmd)