Function buildTimeSeries

storage/remote/queue_manager.go:2112–2135

(timeSeries []prompb.TimeSeries, filter func(prompb.TimeSeries) bool)

}

func buildTimeSeries(timeSeries []prompb.TimeSeries, filter func(prompb.TimeSeries) bool) ([]prompb.TimeSeries, *timeSeriesStats) {
	stats := newTimeSeriesStats()

	timeSeries = slices.DeleteFunc(timeSeries, func(ts prompb.TimeSeries) bool {
		if filter != nil && filter(ts) {
			stats.recordDropped(len(ts.Samples) > 0, len(ts.Exemplars) > 0, len(ts.Histograms) > 0)
			return true
		}

		// At the moment we only ever append a TimeSeries with a single sample or exemplar in it.
		if len(ts.Samples) > 0 {
			stats.updateTimestamp(ts.Samples[0].Timestamp)
		}
		if len(ts.Exemplars) > 0 {
			stats.updateTimestamp(ts.Exemplars[0].Timestamp)
		}
		if len(ts.Histograms) > 0 {
			stats.updateTimestamp(ts.Histograms[0].Timestamp)
		}
		return false
	})

	return timeSeries, stats
}

func buildWriteRequest(logger *slog.Logger, timeSeries []prompb.TimeSeries, metadata []prompb.MetricMetadata, pBuf *proto.Buffer, filter func(prompb.TimeSeries) bool, buf compression.EncodeBuffer, compr compression.Type) (_ []byte, highest, lowest int64, _ error) {
	timeSeries, stats := buildTimeSeries(timeSeries, filter)