Method ToProto

pkg/traceql/engine_metrics.go:350–423

(req *tempopb.QueryRangeRequest)

type SeriesSet map[SeriesMapKey]TimeSeries

func (set SeriesSet) ToProto(req *tempopb.QueryRangeRequest) []*tempopb.TimeSeries {
	mapper := NewIntervalMapperFromReq(req)
	resp := make([]*tempopb.TimeSeries, 0, len(set))

	for _, s := range set {
		labels := make([]commonv1proto.KeyValue, 0, len(s.Labels))
		for _, label := range s.Labels {
			labels = append(labels,
				commonv1proto.KeyValue{
					Key:   label.Name,
					Value: label.Value.AsAnyValue(),
				},
			)
		}

		intervals := mapper.IntervalCount()
		samples := make([]tempopb.Sample, 0, intervals)
		for i, value := range s.Values {
			// todo: this loop should be able to be restructured to directly pass over
			// the desired intervals
			if i >= intervals || math.IsNaN(value) {
				continue
			}

			ts := mapper.TimestampOf(i)
			samples = append(samples, tempopb.Sample{
				TimestampMs: time.Unix(0, int64(ts)).UnixMilli(),
				Value:       value,
			})
		}
		// Do not include empty TimeSeries
		if len(samples) == 0 {
			continue
		}

		var exemplars []tempopb.Exemplar
		if len(s.Exemplars) > 0 {
			exemplars = make([]tempopb.Exemplar, 0, len(s.Exemplars))
		}
		for _, e := range s.Exemplars {
			// skip exemplars that has NaN value
			i := mapper.IntervalMs(int64(e.TimestampMs))
			if i < 0 || i >= len(s.Values) || math.IsNaN(s.Values[i]) { // strict bounds check
				continue
			}

			labels := make([]commonv1proto.KeyValue, 0, len(e.Labels))
			for _, label := range e.Labels {
				labels = append(labels,
					commonv1proto.KeyValue{
						Key:   label.Name,
						Value: label.Value.AsAnyValue(),
					},
				)
			}

			exemplars = append(exemplars, tempopb.Exemplar{
				Labels:      labels,