(req *tempopb.QueryRangeRequest, mode AggregateMode, maxSeriesLimit int)
| 328 | } |
| 329 | |
| 330 | func QueryRangeCombinerFor(req *tempopb.QueryRangeRequest, mode AggregateMode, maxSeriesLimit int) (*QueryRangeCombiner, error) { |
| 331 | eval, err := NewEngine().CompileMetricsQueryRangeNonRaw(req, mode) |
| 332 | if err != nil { |
| 333 | return nil, err |
| 334 | } |
| 335 | |
| 336 | return &QueryRangeCombiner{ |
| 337 | req: req, |
| 338 | eval: eval, |
| 339 | maxSeries: maxSeriesLimit, |
| 340 | metrics: &tempopb.SearchMetrics{}, |
| 341 | }, nil |
| 342 | } |
| 343 | |
| 344 | func (q *QueryRangeCombiner) Combine(resp *tempopb.QueryRangeResponse) { |
| 345 | if resp == nil || q.maxSeriesReached { |
no test coverage detected