(req *tempopb.QueryRangeRequest, results ...SeriesSet)
| 3004 | } |
| 3005 | |
| 3006 | func processLayer3(req *tempopb.QueryRangeRequest, results ...SeriesSet) (SeriesSet, int, error) { |
| 3007 | e := NewEngine() |
| 3008 | |
| 3009 | layer3, err := e.CompileMetricsQueryRangeNonRaw(req, AggregateModeFinal) |
| 3010 | if err != nil { |
| 3011 | return nil, 0, err |
| 3012 | } |
| 3013 | |
| 3014 | for _, res := range results { |
| 3015 | layer3.ObserveSeries(res.ToProto(req)) |
| 3016 | } |
| 3017 | return layer3.Results(), layer3.Length(), nil |
| 3018 | } |
| 3019 | |
| 3020 | func randInt(minimum, maximum int) int { |
| 3021 | return rand.IntN(maximum-minimum) + minimum |
no test coverage detected