mirror of
https://github.com/hanzoai/metrics.git
synced 2026-10-30 20:03:39 +00:00
Zakhar BessarabandGitHub
66e955134d
Updates: - unpin AWS dependencies and run `make vendor-update` - add config options to enable checksums only if required by storage in order to preserve backwards compatibility Related issues: - https://github.com/VictoriaMetrics/VictoriaMetrics/issues/9748 - https://github.com/VictoriaMetrics/VictoriaMetrics/issues/8622 Tested with: AWS S3, self-hosted MinIO, Linode object storage as it was failing previously with multi-part uploads (reported here - https://github.com/VictoriaMetrics/VictoriaMetrics/pull/8630#issuecomment-2772185033). An updated library allows (PR with the fix - https://github.com/aws/aws-sdk-go-v2/pull/3151) overriding multi-part upload configurations so that compatibility can be preserved. Signed-off-by: Zakhar Bessarab <[email protected]>
28 lines
849 B
Go
28 lines
849 B
Go
// Copyright The OpenTelemetry Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package aggregate // import "go.opentelemetry.io/otel/sdk/metric/internal/aggregate"
|
|
|
|
import (
|
|
"context"
|
|
|
|
"go.opentelemetry.io/otel/attribute"
|
|
"go.opentelemetry.io/otel/sdk/metric/exemplar"
|
|
)
|
|
|
|
// dropReservoir returns a [FilteredReservoir] that drops all measurements it is offered.
|
|
func dropReservoir[N int64 | float64](attribute.Set) FilteredExemplarReservoir[N] {
|
|
return &dropRes[N]{}
|
|
}
|
|
|
|
type dropRes[N int64 | float64] struct{}
|
|
|
|
// Offer does nothing, all measurements offered will be dropped.
|
|
func (*dropRes[N]) Offer(context.Context, N, []attribute.KeyValue) {}
|
|
|
|
// Collect resets dest. No exemplars will ever be returned.
|
|
func (*dropRes[N]) Collect(dest *[]exemplar.Exemplar) {
|
|
clear(*dest) // Erase elements to let GC collect objects
|
|
*dest = (*dest)[:0]
|
|
}
|