You've already forked opentelemetry-go
mirror of
https://github.com/open-telemetry/opentelemetry-go.git
synced 2026-06-03 18:35:08 +02:00
28df982c8b
Part of https://github.com/open-telemetry/opentelemetry-go/issues/8110 Related to https://github.com/open-telemetry/opentelemetry-go/issues/5882. I'm hoping to find a better way to support experimental Options types in our API packages. This is one approach to consider. This contains no public API changes. It introduces a type: `ExperimentalOption` in `/metric/internal/x`, which can be used by our experimental options defined outside of the module. Options that embed this interface are ignored by `New*Config` builder functions in the metrics API to prevent them from panicing when used. Only SDKs that explicitly support the experimental option in question will respect it. Alternative SDKs will ignore the experimental options. We would still need to treat ExperimentalOption as a stable artifact, since the SDK will indirectly depend on it. See https://github.com/open-telemetry/opentelemetry-go/compare/main...dashpole:opentelemetry-go:attributes_advisory for how this would be used to support the advisory attributes parameter.
287 lines
9.3 KiB
Go
287 lines
9.3 KiB
Go
// Copyright The OpenTelemetry Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package metric // import "go.opentelemetry.io/otel/metric"
|
|
|
|
import (
|
|
"context"
|
|
|
|
"go.opentelemetry.io/otel/metric/embedded"
|
|
)
|
|
|
|
// Int64Counter is an instrument that records increasing int64 values.
|
|
//
|
|
// Warning: Methods may be added to this interface in minor releases. See
|
|
// package documentation on API implementation for information on how to set
|
|
// default behavior for unimplemented methods.
|
|
type Int64Counter interface {
|
|
// Users of the interface can ignore this. This embedded type is only used
|
|
// by implementations of this interface. See the "API Implementations"
|
|
// section of the package documentation for more information.
|
|
embedded.Int64Counter
|
|
|
|
// Add records a change to the counter.
|
|
//
|
|
// Use the WithAttributeSet (or, if performance is not a concern,
|
|
// the WithAttributes) option to include measurement attributes.
|
|
//
|
|
// Implementations of this method need to be safe for a user to call
|
|
// concurrently.
|
|
Add(ctx context.Context, incr int64, options ...AddOption)
|
|
|
|
// Enabled reports whether the instrument will process measurements for the given context.
|
|
//
|
|
// This function can be used in places where measuring an instrument
|
|
// would result in computationally expensive operations.
|
|
//
|
|
// Implementations of this method need to be safe for a user to call
|
|
// concurrently.
|
|
Enabled(context.Context) bool
|
|
}
|
|
|
|
// Int64CounterConfig contains options for synchronous counter instruments that
|
|
// record int64 values.
|
|
type Int64CounterConfig struct {
|
|
description string
|
|
unit string
|
|
}
|
|
|
|
// NewInt64CounterConfig returns a new [Int64CounterConfig] with all opts
|
|
// applied.
|
|
func NewInt64CounterConfig(opts ...Int64CounterOption) Int64CounterConfig {
|
|
var config Int64CounterConfig
|
|
for _, o := range opts {
|
|
if _, ok := o.(experimentalOption); ok {
|
|
continue
|
|
}
|
|
config = o.applyInt64Counter(config)
|
|
}
|
|
return config
|
|
}
|
|
|
|
// Description returns the configured description.
|
|
func (c Int64CounterConfig) Description() string {
|
|
return c.description
|
|
}
|
|
|
|
// Unit returns the configured unit.
|
|
func (c Int64CounterConfig) Unit() string {
|
|
return c.unit
|
|
}
|
|
|
|
// Int64CounterOption applies options to a [Int64CounterConfig]. See
|
|
// [InstrumentOption] for other options that can be used as an
|
|
// Int64CounterOption.
|
|
type Int64CounterOption interface {
|
|
applyInt64Counter(Int64CounterConfig) Int64CounterConfig
|
|
}
|
|
|
|
// Int64UpDownCounter is an instrument that records increasing or decreasing
|
|
// int64 values.
|
|
//
|
|
// Warning: Methods may be added to this interface in minor releases. See
|
|
// package documentation on API implementation for information on how to set
|
|
// default behavior for unimplemented methods.
|
|
type Int64UpDownCounter interface {
|
|
// Users of the interface can ignore this. This embedded type is only used
|
|
// by implementations of this interface. See the "API Implementations"
|
|
// section of the package documentation for more information.
|
|
embedded.Int64UpDownCounter
|
|
|
|
// Add records a change to the counter.
|
|
//
|
|
// Use the WithAttributeSet (or, if performance is not a concern,
|
|
// the WithAttributes) option to include measurement attributes.
|
|
//
|
|
// Implementations of this method need to be safe for a user to call
|
|
// concurrently.
|
|
Add(ctx context.Context, incr int64, options ...AddOption)
|
|
|
|
// Enabled reports whether the instrument will process measurements for the given context.
|
|
//
|
|
// This function can be used in places where measuring an instrument
|
|
// would result in computationally expensive operations.
|
|
//
|
|
// Implementations of this method need to be safe for a user to call
|
|
// concurrently.
|
|
Enabled(context.Context) bool
|
|
}
|
|
|
|
// Int64UpDownCounterConfig contains options for synchronous counter
|
|
// instruments that record int64 values.
|
|
type Int64UpDownCounterConfig struct {
|
|
description string
|
|
unit string
|
|
}
|
|
|
|
// NewInt64UpDownCounterConfig returns a new [Int64UpDownCounterConfig] with
|
|
// all opts applied.
|
|
func NewInt64UpDownCounterConfig(opts ...Int64UpDownCounterOption) Int64UpDownCounterConfig {
|
|
var config Int64UpDownCounterConfig
|
|
for _, o := range opts {
|
|
if _, ok := o.(experimentalOption); ok {
|
|
continue
|
|
}
|
|
config = o.applyInt64UpDownCounter(config)
|
|
}
|
|
return config
|
|
}
|
|
|
|
// Description returns the configured description.
|
|
func (c Int64UpDownCounterConfig) Description() string {
|
|
return c.description
|
|
}
|
|
|
|
// Unit returns the configured unit.
|
|
func (c Int64UpDownCounterConfig) Unit() string {
|
|
return c.unit
|
|
}
|
|
|
|
// Int64UpDownCounterOption applies options to a [Int64UpDownCounterConfig].
|
|
// See [InstrumentOption] for other options that can be used as an
|
|
// Int64UpDownCounterOption.
|
|
type Int64UpDownCounterOption interface {
|
|
applyInt64UpDownCounter(Int64UpDownCounterConfig) Int64UpDownCounterConfig
|
|
}
|
|
|
|
// Int64Histogram is an instrument that records a distribution of int64
|
|
// values.
|
|
//
|
|
// Warning: Methods may be added to this interface in minor releases. See
|
|
// package documentation on API implementation for information on how to set
|
|
// default behavior for unimplemented methods.
|
|
type Int64Histogram interface {
|
|
// Users of the interface can ignore this. This embedded type is only used
|
|
// by implementations of this interface. See the "API Implementations"
|
|
// section of the package documentation for more information.
|
|
embedded.Int64Histogram
|
|
|
|
// Record adds an additional value to the distribution.
|
|
//
|
|
// Use the WithAttributeSet (or, if performance is not a concern,
|
|
// the WithAttributes) option to include measurement attributes.
|
|
//
|
|
// Implementations of this method need to be safe for a user to call
|
|
// concurrently.
|
|
Record(ctx context.Context, incr int64, options ...RecordOption)
|
|
|
|
// Enabled reports whether the instrument will process measurements for the given context.
|
|
//
|
|
// This function can be used in places where measuring an instrument
|
|
// would result in computationally expensive operations.
|
|
//
|
|
// Implementations of this method need to be safe for a user to call
|
|
// concurrently.
|
|
Enabled(context.Context) bool
|
|
}
|
|
|
|
// Int64HistogramConfig contains options for synchronous histogram instruments
|
|
// that record int64 values.
|
|
type Int64HistogramConfig struct {
|
|
description string
|
|
unit string
|
|
explicitBucketBoundaries []float64
|
|
}
|
|
|
|
// NewInt64HistogramConfig returns a new [Int64HistogramConfig] with all opts
|
|
// applied.
|
|
func NewInt64HistogramConfig(opts ...Int64HistogramOption) Int64HistogramConfig {
|
|
var config Int64HistogramConfig
|
|
for _, o := range opts {
|
|
if _, ok := o.(experimentalOption); ok {
|
|
continue
|
|
}
|
|
config = o.applyInt64Histogram(config)
|
|
}
|
|
return config
|
|
}
|
|
|
|
// Description returns the configured description.
|
|
func (c Int64HistogramConfig) Description() string {
|
|
return c.description
|
|
}
|
|
|
|
// Unit returns the configured unit.
|
|
func (c Int64HistogramConfig) Unit() string {
|
|
return c.unit
|
|
}
|
|
|
|
// ExplicitBucketBoundaries returns the configured explicit bucket boundaries.
|
|
func (c Int64HistogramConfig) ExplicitBucketBoundaries() []float64 {
|
|
return c.explicitBucketBoundaries
|
|
}
|
|
|
|
// Int64HistogramOption applies options to a [Int64HistogramConfig]. See
|
|
// [InstrumentOption] for other options that can be used as an
|
|
// Int64HistogramOption.
|
|
type Int64HistogramOption interface {
|
|
applyInt64Histogram(Int64HistogramConfig) Int64HistogramConfig
|
|
}
|
|
|
|
// Int64Gauge is an instrument that records instantaneous int64 values.
|
|
//
|
|
// Warning: Methods may be added to this interface in minor releases. See
|
|
// package documentation on API implementation for information on how to set
|
|
// default behavior for unimplemented methods.
|
|
type Int64Gauge interface {
|
|
// Users of the interface can ignore this. This embedded type is only used
|
|
// by implementations of this interface. See the "API Implementations"
|
|
// section of the package documentation for more information.
|
|
embedded.Int64Gauge
|
|
|
|
// Record records the instantaneous value.
|
|
//
|
|
// Use the WithAttributeSet (or, if performance is not a concern,
|
|
// the WithAttributes) option to include measurement attributes.
|
|
//
|
|
// Implementations of this method need to be safe for a user to call
|
|
// concurrently.
|
|
Record(ctx context.Context, value int64, options ...RecordOption)
|
|
|
|
// Enabled reports whether the instrument will process measurements for the given context.
|
|
//
|
|
// This function can be used in places where measuring an instrument
|
|
// would result in computationally expensive operations.
|
|
//
|
|
// Implementations of this method need to be safe for a user to call
|
|
// concurrently.
|
|
Enabled(context.Context) bool
|
|
}
|
|
|
|
// Int64GaugeConfig contains options for synchronous gauge instruments that
|
|
// record int64 values.
|
|
type Int64GaugeConfig struct {
|
|
description string
|
|
unit string
|
|
}
|
|
|
|
// NewInt64GaugeConfig returns a new [Int64GaugeConfig] with all opts
|
|
// applied.
|
|
func NewInt64GaugeConfig(opts ...Int64GaugeOption) Int64GaugeConfig {
|
|
var config Int64GaugeConfig
|
|
for _, o := range opts {
|
|
if _, ok := o.(experimentalOption); ok {
|
|
continue
|
|
}
|
|
config = o.applyInt64Gauge(config)
|
|
}
|
|
return config
|
|
}
|
|
|
|
// Description returns the configured description.
|
|
func (c Int64GaugeConfig) Description() string {
|
|
return c.description
|
|
}
|
|
|
|
// Unit returns the configured unit.
|
|
func (c Int64GaugeConfig) Unit() string {
|
|
return c.unit
|
|
}
|
|
|
|
// Int64GaugeOption applies options to a [Int64GaugeConfig]. See
|
|
// [InstrumentOption] for other options that can be used as a
|
|
// Int64GaugeOption.
|
|
type Int64GaugeOption interface {
|
|
applyInt64Gauge(Int64GaugeConfig) Int64GaugeConfig
|
|
}
|