(span Span)
| 557 | } |
| 558 | |
| 559 | func (s *StepAggregator) Observe(span Span) { |
| 560 | interval := s.intervalMapper.Interval(span.StartTimeUnixNanos()) |
| 561 | if interval == -1 { |
| 562 | return |
| 563 | } |
| 564 | s.vectors[interval].Observe(span) |
| 565 | } |
| 566 | |
| 567 | func (s *StepAggregator) ObserveExemplar(value float64, ts uint64, lbls Labels) { |
| 568 | if s.exemplarBuckets.testTotal() { |
nothing calls this directly
no test coverage detected