Function convertV2RequestToV1

pkg/util/push/push.go:208–278

(req *cortexpb.PreallocWriteRequestV2, enableTypeAndUnitLabels bool)

}

func convertV2RequestToV1(req *cortexpb.PreallocWriteRequestV2, enableTypeAndUnitLabels bool) (cortexpb.PreallocWriteRequest, error) {
	var v1Req cortexpb.PreallocWriteRequest
	v1Timeseries := make([]cortexpb.PreallocTimeseries, 0, len(req.Timeseries))
	var v1Metadata []*cortexpb.MetricMetadata

	b := labels.NewScratchBuilder(0)
	symbols := req.Symbols
	for _, v2Ts := range req.Timeseries {
		lbs, err := v2Ts.ToLabels(&b, symbols)
		if err != nil {
			return v1Req, err
		}

		if len(v2Ts.Samples) == 0 && len(v2Ts.Histograms) == 0 {
			return v1Req, fmt.Errorf("TimeSeries must contain at least one sample or histogram for series %v", lbs.String())
		}

		if int(v2Ts.Metadata.UnitRef) >= len(symbols) {
			return v1Req, fmt.Errorf("invalid UnitRef %d: exceeds symbols length %d", v2Ts.Metadata.UnitRef, len(symbols))
		}

		unit := symbols[v2Ts.Metadata.UnitRef]
		metricType := v2Ts.Metadata.Type
		shouldAttachTypeAndUnitLabels := enableTypeAndUnitLabels && (metricType != cortexpb.METRIC_TYPE_UNSPECIFIED || unit != "")
		if shouldAttachTypeAndUnitLabels {
			slb := labels.NewScratchBuilder(lbs.Len() + 2) // for __type__ and __unit__
			lbs.Range(func(l labels.Label) {
				// Skip __type__ and __unit__ labels to prevent duplication,
				// We append these labels from metadata.
				if l.Name != model.MetricTypeLabel && l.Name != model.MetricUnitLabel {
					slb.Add(l.Name, l.Value)
				}
			})
			schema.Metadata{Type: cortexpb.MetadataV2MetricTypeToMetricType(metricType), Unit: unit}.AddToLabels(&slb)
			slb.Sort()
			lbs = slb.Labels()
		}

		exemplars, err := convertV2ToV1Exemplars(&b, symbols, v2Ts.Exemplars)
		if err != nil {
			return v1Req, err
		}

		ts := cortexpb.TimeseriesFromPool()
		ts.Labels = cortexpb.FromLabelsToLabelAdapters(lbs)
		ts.Samples = append(ts.Samples, v2Ts.Samples...)
		ts.Exemplars = exemplars
		ts.Histograms = append(ts.Histograms, v2Ts.Histograms...)

		v1Timeseries = append(v1Timeseries, cortexpb.PreallocTimeseries{
			TimeSeries: ts,
		})

		if shouldConvertV2Metadata(v2Ts.Metadata) {
			metricName, err := extract.MetricNameFromLabels(lbs)
			if err != nil {
				return v1Req, err
			}