diff --git a/src/aggregator/aggregation/counter.go b/src/aggregator/aggregation/counter.go index cf0b338165..58d1a373e8 100644 --- a/src/aggregator/aggregation/counter.go +++ b/src/aggregator/aggregation/counter.go @@ -136,6 +136,4 @@ func (c *Counter) Annotation() []byte { } // Close closes the counter. -func (c *Counter) Close() { - c.annotation = nil -} +func (c *Counter) Close() {} diff --git a/src/aggregator/aggregation/gauge.go b/src/aggregator/aggregation/gauge.go index a2c459b6b7..0f17259185 100644 --- a/src/aggregator/aggregation/gauge.go +++ b/src/aggregator/aggregation/gauge.go @@ -170,6 +170,4 @@ func (g *Gauge) Annotation() []byte { } // Close closes the gauge. -func (g *Gauge) Close() { - g.annotation = nil -} +func (g *Gauge) Close() {} diff --git a/src/aggregator/aggregation/timer.go b/src/aggregator/aggregation/timer.go index 031645aced..edbb5860e2 100644 --- a/src/aggregator/aggregation/timer.go +++ b/src/aggregator/aggregation/timer.go @@ -159,6 +159,5 @@ func (t *Timer) Annotation() []byte { // Close closes the timer. func (t *Timer) Close() { - t.annotation = nil t.stream.Close() }