(span Span)
| 481 | } |
| 482 | |
| 483 | func (g *avgOverTimeSpanAggregator[F, S]) Observe(span Span) { |
| 484 | interval := g.intervalMapper.Interval(span.StartTimeUnixNanos()) |
| 485 | if interval == -1 { |
| 486 | return |
| 487 | } |
| 488 | |
| 489 | inc := g.getSpanAttValue(span) |
| 490 | if math.IsNaN(inc) { |
| 491 | return |
| 492 | } |
| 493 | |
| 494 | s := g.getSeries(span) |
| 495 | s.average.addIncrementMean(interval, inc) |
| 496 | } |
| 497 | |
| 498 | func (g *avgOverTimeSpanAggregator[F, S]) ObserveExemplar(span Span, value float64, ts uint64) { |
| 499 | s := g.getSeries(span) |
nothing calls this directly
no test coverage detected