Function convertToPromTS

pkg/util/push/otlp.go:184–216

(ctx context.Context, pmetrics pmetric.Metrics, cfg distributor.OTLPConfig, overrides *validation.Overrides, userID string, logger log.Logger)

}

func convertToPromTS(ctx context.Context, pmetrics pmetric.Metrics, cfg distributor.OTLPConfig, overrides *validation.Overrides, userID string, logger log.Logger) ([]prompb.TimeSeries, []prompb.MetricMetadata, error) {
	collector := newCollectingAppender()
	promConverter := prometheusremotewrite.NewPrometheusConverter(collector)
	settings := prometheusremotewrite.Settings{
		AddMetricSuffixes:       cfg.AddMetricSuffixes,
		DisableTargetInfo:       cfg.DisableTargetInfo,
		AllowDeltaTemporality:   cfg.AllowDeltaTemporality,
		EnableTypeAndUnitLabels: overrides.EnableTypeAndUnitLabels(userID),
	}

	var annots annotations.Annotations
	var err error

	if cfg.ConvertAllAttributes {
		annots, err = promConverter.FromMetrics(ctx, convertToMetricsAttributes(pmetrics), settings)
	} else {
		settings.PromoteResourceAttributes = prometheusremotewrite.NewPromoteResourceAttributes(config.OTLPConfig{
			PromoteResourceAttributes: overrides.PromoteResourceAttributes(userID),
		})
		annots, err = promConverter.FromMetrics(ctx, pmetrics, settings)
	}

	ws, _ := annots.AsStrings("", 0, 0)
	if len(ws) > 0 {
		level.Warn(logger).Log("msg", "Warnings translating OTLP metrics to Prometheus write request", "warnings", ws)
	}

	if err != nil {
		level.Warn(logger).Log("msg", "Error translating OTLP metrics to Prometheus write request", "err", err)
	}

	return collector.TimeSeries(), collector.Metadata(), err
}

func makeLabels(in []prompb.Label) []cortexpb.LabelAdapter {
	builder := labels.NewBuilder(labels.EmptyLabels())