diff options
Diffstat (limited to 'vendor/go.opentelemetry.io/otel/sdk/metric/meter.go')
| -rw-r--r-- | vendor/go.opentelemetry.io/otel/sdk/metric/meter.go | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/vendor/go.opentelemetry.io/otel/sdk/metric/meter.go b/vendor/go.opentelemetry.io/otel/sdk/metric/meter.go index abff4650e..2309e5b2b 100644 --- a/vendor/go.opentelemetry.io/otel/sdk/metric/meter.go +++ b/vendor/go.opentelemetry.io/otel/sdk/metric/meter.go @@ -459,7 +459,7 @@ func (m *meter) RegisterCallback(f metric.Callback, insts ...metric.Observable) } continue } - reg.registerInt64(o.observableID) + reg.registerInt64(o.observablID) case float64Observable: if err := o.registerable(m); err != nil { if !errors.Is(err, errEmptyAgg) { @@ -467,7 +467,7 @@ func (m *meter) RegisterCallback(f metric.Callback, insts ...metric.Observable) } continue } - reg.registerFloat64(o.observableID) + reg.registerFloat64(o.observablID) default: // Instrument external to the SDK. return nil, fmt.Errorf("invalid observable: from different implementation") @@ -488,14 +488,14 @@ func (m *meter) RegisterCallback(f metric.Callback, insts ...metric.Observable) type observer struct { embedded.Observer - float64 map[observableID[float64]]struct{} - int64 map[observableID[int64]]struct{} + float64 map[observablID[float64]]struct{} + int64 map[observablID[int64]]struct{} } func newObserver() observer { return observer{ - float64: make(map[observableID[float64]]struct{}), - int64: make(map[observableID[int64]]struct{}), + float64: make(map[observablID[float64]]struct{}), + int64: make(map[observablID[int64]]struct{}), } } @@ -503,11 +503,11 @@ func (r observer) len() int { return len(r.float64) + len(r.int64) } -func (r observer) registerFloat64(id observableID[float64]) { +func (r observer) registerFloat64(id observablID[float64]) { r.float64[id] = struct{}{} } -func (r observer) registerInt64(id observableID[int64]) { +func (r observer) registerInt64(id observablID[int64]) { r.int64[id] = struct{}{} } @@ -536,7 +536,7 @@ func (r observer) ObserveFloat64(o metric.Float64Observable, v float64, opts ... return } - if _, registered := r.float64[oImpl.observableID]; !registered { + if _, registered := r.float64[oImpl.observablID]; !registered { if !oImpl.dropAggregation { global.Error(errUnregObserver, "failed to record", "name", oImpl.name, @@ -571,7 +571,7 @@ func (r observer) ObserveInt64(o metric.Int64Observable, v int64, opts ...metric return } - if _, registered := r.int64[oImpl.observableID]; !registered { + if _, registered := r.int64[oImpl.observablID]; !registered { if !oImpl.dropAggregation { global.Error(errUnregObserver, "failed to record", "name", oImpl.name, |