(q *tempopb.QueryRangeRequest)
| 254 | } |
| 255 | |
| 256 | func (a *MetricsAggregate) initFinal(q *tempopb.QueryRangeRequest) { |
| 257 | switch a.op { |
| 258 | case metricsAggregateQuantileOverTime: |
| 259 | a.seriesAgg = NewHistogramAggregator(q, a.floats, q.Exemplars) |
| 260 | default: |
| 261 | // These are simple additions by series |
| 262 | a.seriesAgg = NewSimpleCombiner(q, a.simpleAggregationOp) |
| 263 | } |
| 264 | } |
| 265 | |
| 266 | func (a *MetricsAggregate) observe(span Span) { |
| 267 | a.agg.Observe(span) |
no test coverage detected