Function ToWriteRequest

pkg/cortexpb/compat.go:23–45

ToWriteRequest converts matched slices of Labels, Samples, Metadata and Histograms into a WriteRequest proto. It gets timeseries from the pool, so ReuseSlice() should be called when done.

(lbls []labels.Labels, samples []Sample, metadata []*MetricMetadata, histograms []WrappedHistogram, source SourceEnum)

// ToWriteRequest converts matched slices of Labels, Samples, Metadata and Histograms into a WriteRequest proto.
// It gets timeseries from the pool, so ReuseSlice() should be called when done.
func ToWriteRequest(lbls []labels.Labels, samples []Sample, metadata []*MetricMetadata, histograms []WrappedHistogram, source SourceEnum) *WriteRequest {
	req := &WriteRequest{
		Timeseries: PreallocTimeseriesSliceFromPool(),
		Metadata:   metadata,
		Source:     source,
	}

	i := 0
	for i < len(samples) || i < len(histograms) {
		ts := TimeseriesFromPool()
		ts.Labels = append(ts.Labels, FromLabelsToLabelAdapters(lbls[i])...)
		if i < len(samples) {
			ts.Samples = append(ts.Samples, samples[i])
		}
		if i < len(histograms) {
			ts.Histograms = append(ts.Histograms, histograms[i])
		}
		i++
		req.Timeseries = append(req.Timeseries, PreallocTimeseries{TimeSeries: ts})
	}

	return req
}

func (w *WriteRequest) AddHistogramTimeSeries(lbls []labels.Labels, histograms []WrappedHistogram) {
	for i := range lbls {