mirror of
https://github.com/hanzoai/telemetry.git
synced 2026-10-30 20:01:49 +00:00
1a30d986a4
<!--Ex. Fixing a bug - Describe the bug and how this fixes the issue. Ex. Adding a feature - Explain what this achieves.--> #### Description <!-- Issue number if applicable --> #### Link to tracking issue Fixes # <!--Describe what testing was performed and which tests were added.--> #### Testing <!--Describe the documentation added.--> #### Documentation <!--Please delete paragraphs that you did not use before submitting.--> Signed-off-by: Bogdan Drutu <[email protected]> Co-authored-by: Alex Boten <[email protected]>
39 lines
1.4 KiB
Go
39 lines
1.4 KiB
Go
// Copyright The OpenTelemetry Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package pref // import "go.opentelemetry.io/collector/pdata/xpdata/pref"
|
|
|
|
import (
|
|
"reflect"
|
|
|
|
"go.opentelemetry.io/collector/pdata/internal"
|
|
pmetadata "go.opentelemetry.io/collector/pdata/internal/metadata"
|
|
"go.opentelemetry.io/collector/pdata/pmetric"
|
|
)
|
|
|
|
// MarkPipelineOwnedMetrics marks the pmetric.Metrics data as owned by the pipeline, returns true if the data were
|
|
// previously not owned by the pipeline, otherwise false.
|
|
func MarkPipelineOwnedMetrics(md pmetric.Metrics) bool {
|
|
return internal.GetMetricsState(internal.MetricsWrapper(md)).MarkPipelineOwned()
|
|
}
|
|
|
|
func RefMetrics(md pmetric.Metrics) {
|
|
internal.GetMetricsState(internal.MetricsWrapper(md)).Ref()
|
|
}
|
|
|
|
func UnrefMetrics(md pmetric.Metrics) {
|
|
if !internal.GetMetricsState(internal.MetricsWrapper(md)).Unref() {
|
|
return
|
|
}
|
|
// Don't call DeleteExportLogsServiceRequest without the gate because we reset the data and that may still cause issues.
|
|
if pmetadata.PdataUseProtoPoolingFeatureGate.IsEnabled() {
|
|
internal.DeleteExportMetricsServiceRequest(internal.GetMetricsOrig(internal.MetricsWrapper(md)), true)
|
|
}
|
|
}
|
|
|
|
// TODO: Generate this in pdata.
|
|
|
|
func EqualMetrics(md1, md2 pmetric.Metrics) bool {
|
|
return reflect.DeepEqual(internal.GetMetricsOrig(internal.MetricsWrapper(md1)), internal.GetMetricsOrig(internal.MetricsWrapper(md2)))
|
|
}
|