Convert Timeseries to Metrics
(timeseries []prompb.TimeSeries, metadata []prompb.MetricMetadata)
| 275 | |
| 276 | // Convert Timeseries to Metrics |
| 277 | func convertTimeseriesToMetrics(timeseries []prompb.TimeSeries, metadata []prompb.MetricMetadata) pmetric.Metrics { |
| 278 | metrics := pmetric.NewMetrics() |
| 279 | for i, ts := range timeseries { |
| 280 | metricName, attributes := getNameAndAttributes(ts) |
| 281 | newMetric := metrics.ResourceMetrics().AppendEmpty().ScopeMetrics().AppendEmpty().Metrics().AppendEmpty() |
| 282 | newMetric.SetName(metricName) |
| 283 | |
| 284 | if metadata != nil { |
| 285 | newMetric.SetDescription(metadata[i].GetHelp()) |
| 286 | newMetric.SetUnit(metadata[i].GetUnit()) |
| 287 | } |
| 288 | |
| 289 | if len(ts.Samples) > 0 { |
| 290 | createDataPointsGauge(newMetric, attributes, ts.Samples) |
| 291 | } else if len(ts.Histograms) > 0 { |
| 292 | createDataPointsExponentialHistogram(newMetric, attributes, ts.Histograms) |
| 293 | } |
| 294 | } |
| 295 | return metrics |
| 296 | } |
| 297 | |
| 298 | func otlpWriteRequest(name, unit string, temporality pmetric.AggregationTemporality, labels ...prompb.Label) pmetricotlp.ExportRequest { |
| 299 | d := pmetric.NewMetrics() |
no test coverage detected