Method TopN

module/monitor/driver/influxdb-v2/executor.go:613–645

(ctx context.Context, start time.Time, end time.Time, limit int, groupBy string, wheres []monitor.MonWhereItem)

}

func (e *executor) TopN(ctx context.Context, start time.Time, end time.Time, limit int, groupBy string, wheres []monitor.MonWhereItem) ([]*monitor.TopN, error) {
	filters := formatFilter(wheres)
	newStartTime, _, _, bucket := getTimeIntervalAndBucket(start, end)

	statisticsConf := []*flux.StatisticsFilterConf{
		{
			Measurement: "request",
			AggregateFn: "sum()",
			Fields:      []string{"total", "request", "response", "input_token", "output_token"},
		},
		{
			Measurement: "proxy",
			AggregateFn: "sum()",
			Fields:      []string{"p_total"},
		},
	}

	results, err := e.fluxQuery.CommonStatistics(ctx, e.openApi, newStartTime, end, bucket, groupBy, filters, statisticsConf, limit)
	if err != nil {
		return nil, err
	}
	topN := make([]*monitor.TopN, 0, len(results))
	for key, result := range results {
		n := new(monitor.TopN)
		n.Key = key
		n.Request = result.Total
		n.Token = result.TotalToken
		n.Traffic = result.TotalRequest + result.TotalResponse
		topN = append(topN, n)
	}

	return topN, nil
}

func (e *executor) TokenOverview(ctx context.Context, start time.Time, end time.Time, wheres []monitor.MonWhereItem) ([]time.Time, *monitor.TokenOverview, []*monitor.TokenOverview, error) {
	newStartTime, every, windowOffset, bucket := getTimeIntervalAndBucket(start, end)