mirror of
https://github.com/hanzoai/traces.git
synced 2026-11-03 04:05:45 +00:00
* Update Prometheus to v0.307.2 * Update otel collector * Update OTel collector
75 lines
2.1 KiB
Go
75 lines
2.1 KiB
Go
// Copyright The OpenTelemetry Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package internal // import "go.opentelemetry.io/collector/pdata/internal"
|
|
|
|
import (
|
|
otlpcommon "go.opentelemetry.io/collector/pdata/internal/data/protogen/common/v1"
|
|
)
|
|
|
|
type Value struct {
|
|
orig *otlpcommon.AnyValue
|
|
state *State
|
|
}
|
|
|
|
func GetOrigValue(ms Value) *otlpcommon.AnyValue {
|
|
return ms.orig
|
|
}
|
|
|
|
func GetValueState(ms Value) *State {
|
|
return ms.state
|
|
}
|
|
|
|
func NewValue(orig *otlpcommon.AnyValue, state *State) Value {
|
|
return Value{orig: orig, state: state}
|
|
}
|
|
|
|
func NewOrigAnyValueStringValue() *otlpcommon.AnyValue_StringValue {
|
|
if !UseProtoPooling.IsEnabled() {
|
|
return &otlpcommon.AnyValue_StringValue{}
|
|
}
|
|
return ProtoPoolAnyValue_StringValue.Get().(*otlpcommon.AnyValue_StringValue)
|
|
}
|
|
|
|
func NewOrigAnyValueIntValue() *otlpcommon.AnyValue_IntValue {
|
|
if !UseProtoPooling.IsEnabled() {
|
|
return &otlpcommon.AnyValue_IntValue{}
|
|
}
|
|
return ProtoPoolAnyValue_IntValue.Get().(*otlpcommon.AnyValue_IntValue)
|
|
}
|
|
|
|
func NewOrigAnyValueBoolValue() *otlpcommon.AnyValue_BoolValue {
|
|
if !UseProtoPooling.IsEnabled() {
|
|
return &otlpcommon.AnyValue_BoolValue{}
|
|
}
|
|
return ProtoPoolAnyValue_BoolValue.Get().(*otlpcommon.AnyValue_BoolValue)
|
|
}
|
|
|
|
func NewOrigAnyValueDoubleValue() *otlpcommon.AnyValue_DoubleValue {
|
|
if !UseProtoPooling.IsEnabled() {
|
|
return &otlpcommon.AnyValue_DoubleValue{}
|
|
}
|
|
return ProtoPoolAnyValue_DoubleValue.Get().(*otlpcommon.AnyValue_DoubleValue)
|
|
}
|
|
|
|
func NewOrigAnyValueBytesValue() *otlpcommon.AnyValue_BytesValue {
|
|
if !UseProtoPooling.IsEnabled() {
|
|
return &otlpcommon.AnyValue_BytesValue{}
|
|
}
|
|
return ProtoPoolAnyValue_BytesValue.Get().(*otlpcommon.AnyValue_BytesValue)
|
|
}
|
|
|
|
func NewOrigAnyValueArrayValue() *otlpcommon.AnyValue_ArrayValue {
|
|
if !UseProtoPooling.IsEnabled() {
|
|
return &otlpcommon.AnyValue_ArrayValue{}
|
|
}
|
|
return ProtoPoolAnyValue_ArrayValue.Get().(*otlpcommon.AnyValue_ArrayValue)
|
|
}
|
|
|
|
func NewOrigAnyValueKvlistValue() *otlpcommon.AnyValue_KvlistValue {
|
|
if !UseProtoPooling.IsEnabled() {
|
|
return &otlpcommon.AnyValue_KvlistValue{}
|
|
}
|
|
return ProtoPoolAnyValue_KvlistValue.Get().(*otlpcommon.AnyValue_KvlistValue)
|
|
}
|