(ctx context.Context, start, end time.Time, bucket string, filters string, filterCfg *flux.StatisticsFilterConf, prefix string)
| 255 | } |
| 256 | |
| 257 | func (e *executor) summary(ctx context.Context, start, end time.Time, bucket string, filters string, filterCfg *flux.StatisticsFilterConf, prefix string) (*monitor.Summary, error) { |
| 258 | //获取请求表的饼状图 |
| 259 | queryOnce, err := e.fluxQuery.CommonQueryOnce(ctx, e.openApi, start, end, bucket, filters, filterCfg) |
| 260 | if err != nil { |
| 261 | return nil, err |
| 262 | } |
| 263 | summary := new(monitor.Summary) |
| 264 | if v, ok := queryOnce[prefix+"s4xx"]; ok { |
| 265 | summary.Status4Xx = common.FmtIntFromInterface(v) |
| 266 | } |
| 267 | if v, ok := queryOnce[prefix+"s5xx"]; ok { |
| 268 | summary.Status5Xx = common.FmtIntFromInterface(v) |
| 269 | } |
| 270 | if v, ok := queryOnce[prefix+"success"]; ok { |
| 271 | summary.Success = common.FmtIntFromInterface(v) |
| 272 | } |
| 273 | if v, ok := queryOnce[prefix+"total"]; ok { |
| 274 | summary.Total = common.FmtIntFromInterface(v) |
| 275 | } |
| 276 | summary.Fail = summary.Total - summary.Success |
| 277 | return summary, nil |
| 278 | } |
| 279 | |
| 280 | func (e *executor) RequestSummary(ctx context.Context, start time.Time, end time.Time, wheres []monitor.MonWhereItem) (*monitor.Summary, error) { |
| 281 | newStartTime, _, _, bucket := getTimeIntervalAndBucket(start, end) |
no test coverage detected