(ctx context.Context, start time.Time, end time.Time, wheres []monitor.MonWhereItem)
| 287 | } |
| 288 | |
| 289 | func (e *executor) ProxySummary(ctx context.Context, start time.Time, end time.Time, wheres []monitor.MonWhereItem) (*monitor.Summary, error) { |
| 290 | newStartTime, _, _, bucket := getTimeIntervalAndBucket(start, end) |
| 291 | return e.summary(ctx, newStartTime, end, bucket, formatFilter(wheres), &flux.StatisticsFilterConf{ |
| 292 | Measurement: "proxy", |
| 293 | AggregateFn: "sum()", |
| 294 | Fields: []string{"p_total", "p_success", "p_s4xx", "p_s5xx"}, |
| 295 | }, "p_") |
| 296 | } |
| 297 | |
| 298 | func (e *executor) CommonStatistics(ctx context.Context, start, end time.Time, groupBy string, limit int, wheres []monitor.MonWhereItem) (map[string]monitor.MonCommonData, error) { |
| 299 | filters := formatFilter(wheres) |
nothing calls this directly
no test coverage detected