(span Span, value float64, ts uint64)
| 809 | } |
| 810 | |
| 811 | func (g *GroupingAggregator[F, S]) ObserveExemplar(span Span, value float64, ts uint64) { |
| 812 | if !g.getGroupingValues(span) { |
| 813 | return |
| 814 | } |
| 815 | |
| 816 | s := g.getSeries() |
| 817 | |
| 818 | // Observe exemplar |
| 819 | all := span.AllAttributes() |
| 820 | lbls := make(Labels, 0, len(all)) |
| 821 | for k, v := range span.AllAttributes() { |
| 822 | lbls = append(lbls, Label{k.String(), v}) |
| 823 | } |
| 824 | s.agg.ObserveExemplar(value, ts, lbls) |
| 825 | } |
| 826 | |
| 827 | func (g *GroupingAggregator[F, S]) Length() int { |
| 828 | return len(g.series) |
nothing calls this directly
no test coverage detected