(req *tempopb.QueryRangeRequest, topN int, exemplars uint32)
| 366 | } |
| 367 | |
| 368 | func NewBaselineAggregator(req *tempopb.QueryRangeRequest, topN int, exemplars uint32) *BaselineAggregator { |
| 369 | return &BaselineAggregator{ |
| 370 | baseline: make(map[string]map[StaticMapKey]staticWithTimeSeries), |
| 371 | selection: make(map[string]map[StaticMapKey]staticWithTimeSeries), |
| 372 | baselineTotals: make(map[string]map[StaticMapKey]staticWithTimeSeries), |
| 373 | selectionTotals: make(map[string]map[StaticMapKey]staticWithTimeSeries), |
| 374 | maxed: make(map[string]struct{}), |
| 375 | intervalMapper: NewIntervalMapperFromReq(req), |
| 376 | topN: topN, |
| 377 | exemplarBuckets: newExemplarBucketSet(exemplars, req.Start, req.End, req.Step, IsInstant(req)), |
| 378 | } |
| 379 | } |
| 380 | |
| 381 | func (b *BaselineAggregator) Combine(ss []*tempopb.TimeSeries) { |
| 382 | for _, s := range ss { |
no test coverage detected