summaryrefslogtreecommitdiff
path: root/vendor/go.opentelemetry.io/otel/sdk/metric/exemplar.go
diff options
context:
space:
mode:
Diffstat (limited to 'vendor/go.opentelemetry.io/otel/sdk/metric/exemplar.go')
-rw-r--r--vendor/go.opentelemetry.io/otel/sdk/metric/exemplar.go77
1 files changed, 0 insertions, 77 deletions
diff --git a/vendor/go.opentelemetry.io/otel/sdk/metric/exemplar.go b/vendor/go.opentelemetry.io/otel/sdk/metric/exemplar.go
deleted file mode 100644
index 0335b8ae4..000000000
--- a/vendor/go.opentelemetry.io/otel/sdk/metric/exemplar.go
+++ /dev/null
@@ -1,77 +0,0 @@
-// Copyright The OpenTelemetry Authors
-// SPDX-License-Identifier: Apache-2.0
-
-package metric // import "go.opentelemetry.io/otel/sdk/metric"
-
-import (
- "runtime"
-
- "go.opentelemetry.io/otel/attribute"
- "go.opentelemetry.io/otel/sdk/metric/exemplar"
- "go.opentelemetry.io/otel/sdk/metric/internal/aggregate"
-)
-
-// ExemplarReservoirProviderSelector selects the
-// [exemplar.ReservoirProvider] to use
-// based on the [Aggregation] of the metric.
-type ExemplarReservoirProviderSelector func(Aggregation) exemplar.ReservoirProvider
-
-// reservoirFunc returns the appropriately configured exemplar reservoir
-// creation func based on the passed InstrumentKind and filter configuration.
-func reservoirFunc[N int64 | float64](provider exemplar.ReservoirProvider, filter exemplar.Filter) func(attribute.Set) aggregate.FilteredExemplarReservoir[N] {
- return func(attrs attribute.Set) aggregate.FilteredExemplarReservoir[N] {
- return aggregate.NewFilteredExemplarReservoir[N](filter, provider(attrs))
- }
-}
-
-// DefaultExemplarReservoirProviderSelector returns the default
-// [exemplar.ReservoirProvider] for the
-// provided [Aggregation].
-//
-// For explicit bucket histograms with more than 1 bucket, it uses the
-// [exemplar.HistogramReservoirProvider].
-// For exponential histograms, it uses the
-// [exemplar.FixedSizeReservoirProvider]
-// with a size of min(20, max_buckets).
-// For all other aggregations, it uses the
-// [exemplar.FixedSizeReservoirProvider]
-// with a size equal to the number of CPUs.
-//
-// Exemplar default reservoirs MAY change in a minor version bump. No
-// guarantees are made on the shape or statistical properties of returned
-// exemplars.
-func DefaultExemplarReservoirProviderSelector(agg Aggregation) exemplar.ReservoirProvider {
- // https://github.com/open-telemetry/opentelemetry-specification/blob/d4b241f451674e8f611bb589477680341006ad2b/specification/metrics/sdk.md#exemplar-defaults
- // Explicit bucket histogram aggregation with more than 1 bucket will
- // use AlignedHistogramBucketExemplarReservoir.
- a, ok := agg.(AggregationExplicitBucketHistogram)
- if ok && len(a.Boundaries) > 0 {
- return exemplar.HistogramReservoirProvider(a.Boundaries)
- }
-
- var n int
- if a, ok := agg.(AggregationBase2ExponentialHistogram); ok {
- // Base2 Exponential Histogram Aggregation SHOULD use a
- // SimpleFixedSizeExemplarReservoir with a reservoir equal to the
- // smaller of the maximum number of buckets configured on the
- // aggregation or twenty (e.g. min(20, max_buckets)).
- n = int(a.MaxSize)
- if n > 20 {
- n = 20
- }
- } else {
- // https://github.com/open-telemetry/opentelemetry-specification/blob/e94af89e3d0c01de30127a0f423e912f6cda7bed/specification/metrics/sdk.md#simplefixedsizeexemplarreservoir
- // This Exemplar reservoir MAY take a configuration parameter for
- // the size of the reservoir. If no size configuration is
- // provided, the default size MAY be the number of possible
- // concurrent threads (e.g. number of CPUs) to help reduce
- // contention. Otherwise, a default size of 1 SHOULD be used.
- n = runtime.NumCPU()
- if n < 1 {
- // Should never be the case, but be defensive.
- n = 1
- }
- }
-
- return exemplar.FixedSizeReservoirProvider(n)
-}