transform

Documentation

Overview

Package transform provides transformation functionality from the sdk/metric/metricdata data-types into OTLP data-types.

Index

• func AttrIter(iter attribute.Iterator) []*cpb.KeyValue
• func DataPoints[N int64 | float64](dPts []metricdata.DataPoint[N]) []*mpb.NumberDataPoint
• func Gauge[N int64 | float64](g metricdata.Gauge[N]) *mpb.Metric_Gauge
• func Histogram(h metricdata.Histogram) (*mpb.Metric_Histogram, error)
• func HistogramDataPoints(dPts []metricdata.HistogramDataPoint) []*mpb.HistogramDataPoint
• func KeyValue(kv attribute.KeyValue) *cpb.KeyValue
• func KeyValues(attrs []attribute.KeyValue) []*cpb.KeyValue
• func Metrics(ms []metricdata.Metrics) ([]*mpb.Metric, error)
• func ResourceMetrics(rm metricdata.ResourceMetrics) (*mpb.ResourceMetrics, error)
• func ScopeMetrics(sms []metricdata.ScopeMetrics) ([]*mpb.ScopeMetrics, error)
• func Sum[N int64 | float64](s metricdata.Sum[N]) (*mpb.Metric_Sum, error)
• func Temporality(t metricdata.Temporality) (mpb.AggregationTemporality, error)
• func Value(v attribute.Value) *cpb.AnyValue

Functions

func AttrIter

func AttrIter(iter attribute.Iterator) []*cpb.KeyValue

AttrIter transforms an attribute iterator into OTLP key-values.

func DataPoints

func DataPoints[N int64 | float64](dPts []metricdata.DataPoint[N]) []*mpb.NumberDataPoint

DataPoints returns a slice of OTLP NumberDataPoint generated from dPts.

func Gauge

func Gauge[N int64 | float64](g metricdata.Gauge[N]) *mpb.Metric_Gauge

Gauge returns an OTLP Metric_Gauge generated from g.

func Histogram

func Histogram(h metricdata.Histogram) (*mpb.Metric_Histogram, error)

Histogram returns an OTLP Metric_Histogram generated from h. An error is returned with a partial Metric_Histogram if the temporality of h is unknown.

func HistogramDataPoints

func HistogramDataPoints(dPts []metricdata.HistogramDataPoint) []*mpb.HistogramDataPoint

HistogramDataPoints returns a slice of OTLP HistogramDataPoint generated from dPts.

func KeyValue

func KeyValue(kv attribute.KeyValue) *cpb.KeyValue

KeyValue transforms an attribute KeyValue into an OTLP key-value.

func KeyValues

func KeyValues(attrs []attribute.KeyValue) []*cpb.KeyValue

KeyValues transforms a slice of attribute KeyValues into OTLP key-values.

func Metrics

func Metrics(ms []metricdata.Metrics) ([]*mpb.Metric, error)

Metrics returns a slice of OTLP Metric generated from ms. If ms contains invalid metric values, an error will be returned along with a slice that contains partial OTLP Metrics.

func ResourceMetrics

func ResourceMetrics(rm metricdata.ResourceMetrics) (*mpb.ResourceMetrics, error)

ResourceMetrics returns an OTLP ResourceMetrics generated from rm. If rm contains invalid ScopeMetrics, an error will be returned along with an OTLP ResourceMetrics that contains partial OTLP ScopeMetrics.

func ScopeMetrics

func ScopeMetrics(sms []metricdata.ScopeMetrics) ([]*mpb.ScopeMetrics, error)

ScopeMetrics returns a slice of OTLP ScopeMetrics generated from sms. If sms contains invalid metric values, an error will be returned along with a slice that contains partial OTLP ScopeMetrics.

func Sum

func Sum[N int64 | float64](s metricdata.Sum[N]) (*mpb.Metric_Sum, error)

Sum returns an OTLP Metric_Sum generated from s. An error is returned with a partial Metric_Sum if the temporality of s is unknown.

func Temporality

func Temporality(t metricdata.Temporality) (mpb.AggregationTemporality, error)

Temporality returns an OTLP AggregationTemporality generated from t. If t is unknown, an error is returned along with the invalid AggregationTemporality_AGGREGATION_TEMPORALITY_UNSPECIFIED.

func Value

func Value(v attribute.Value) *cpb.AnyValue

Value transforms an attribute Value into an OTLP AnyValue.