Add aggregator to pipeline

open-telemetry · Sep 27, 2022 · 3a0d895 · 3a0d895
1 parent 7058204
commit 3a0d895
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/sdk/metric/pipeline.go b/sdk/metric/pipeline.go
@@ -233,6 +233,10 @@ func (i *inserter[N]) Instrument(inst view.Instrument, instUnit unit.Unit) ([]in
 		}
 		if a != nil {
 			aggs = append(aggs, a)
+			err = i.pipeline.addAggregator(inst.Scope, inst.Name, inst.Description, instUnit, a)
+			if err != nil {
+				errs.append(err)
+			}
 		}
 	}