Function statsQuery

cli/ctl/promql.go:169–212

(cmd *cobra.Command, from, to int64, metric string, targetLabels, appLabels []string)

}

func statsQuery(cmd *cobra.Command, from, to int64, metric string, targetLabels, appLabels []string) error {
	server := common.GetServerInfo(cmd)
	url := fmt.Sprintf("http://%s:%d/prom/api/v1/analysis?from=%d&to=%d", server.IP, server.Port, from, to)
	if metric != "" {
		url += fmt.Sprintf("&metric=%s", metric)
	}
	if len(targetLabels) > 0 {
		url += fmt.Sprintf("&target=%s", strings.Join(targetLabels, ","))
	}
	if len(appLabels) > 0 {
		url += fmt.Sprintf("&app=%s", strings.Join(appLabels, ","))
	}
	response, err := common.CURLPerform("GET", url, nil, "", []common.HTTPOption{common.WithTimeout(common.GetTimeout(cmd)), common.WithORGID(common.GetORGID(cmd))}...)
	if err != nil {
		fmt.Println(err)
		return err
	}

	t := table.New()
	t.SetHeader(response.Get("Columns").MustStringArray())
	tableItems := make([][]string, 0, len(response.Get("Values").MustArray()))
	var rowItems []string
	for i := range response.Get("Values").MustArray() {
		row := response.Get("Values").GetIndex(i)
		rowItems = make([]string, 0, len(response.Get("Columns").MustStringArray()))
		for k, v := range response.Get("Columns").MustStringArray() {
			col := row.GetIndex(k)
			var val string
			switch strings.ToUpper(v) {
			case "QUERY_COUNT":
				val = strconv.Itoa(col.MustInt())
			case "AVG_DURATION(MS)", "MAX_DURATION(MS)":
				val = fmt.Sprintf("%f", col.MustFloat64())
			default:
				val = col.MustString()
			}
			rowItems = append(rowItems, val)
		}
		tableItems = append(tableItems, rowItems)
	}
	t.AppendBulk(tableItems)
	t.Render()
	return nil
}