diff --git a/sdk/metric/meter.go b/sdk/metric/meter.go index 421e9a4dccf..b53a6c43566 100644 --- a/sdk/metric/meter.go +++ b/sdk/metric/meter.go @@ -641,24 +641,6 @@ func (p float64InstProvider) lookupHistogram(name string, cfg metric.Float64Hist type int64ObservProvider struct{ *meter } -func (p int64ObservProvider) lookup(kind InstrumentKind, name, desc, u string) (int64Observable, error) { - aggs, err := (int64InstProvider)(p).aggs(kind, name, desc, u) - inst := newInt64Observable(p.meter, kind, name, desc, u) - inst.appendMeasures(aggs) - return inst, err -} - -func (p int64ObservProvider) registerCallbacks(m measures[int64], cBacks []metric.Int64Callback) { - if len(m) == 0 { - // Drop aggregator. - return - } - - for _, cBack := range cBacks { - p.pipes.registerCallback(p.callback(m, cBack)) - } -} - func (p int64ObservProvider) callback(m measures[int64], f metric.Int64Callback) func(context.Context) error { inst := int64Observer{measures: m} return func(ctx context.Context) error { return f(ctx, inst) } @@ -676,24 +658,6 @@ func (o int64Observer) Observe(val int64, opts ...metric.ObserveOption) { type float64ObservProvider struct{ *meter } -func (p float64ObservProvider) lookup(kind InstrumentKind, name, desc, u string) (float64Observable, error) { - aggs, err := (float64InstProvider)(p).aggs(kind, name, desc, u) - inst := newFloat64Observable(p.meter, kind, name, desc, u) - inst.appendMeasures(aggs) - return inst, err -} - -func (p float64ObservProvider) registerCallbacks(m measures[float64], cBacks []metric.Float64Callback) { - if len(m) == 0 { - // Drop aggregator. - return - } - - for _, cBack := range cBacks { - p.pipes.registerCallback(p.callback(m, cBack)) - } -} - func (p float64ObservProvider) callback(m measures[float64], f metric.Float64Callback) func(context.Context) error { inst := float64Observer{measures: m} return func(ctx context.Context) error { return f(ctx, inst) }