diff --git a/storage/metric/memory.go b/storage/metric/memory.go index 6187b7923..252d1ac60 100644 --- a/storage/metric/memory.go +++ b/storage/metric/memory.go @@ -141,6 +141,10 @@ func (s *stream) getRangeValues(in model.Interval) model.Values { return result } +func (s *stream) empty() bool { + return len(s.values) == 0 +} + func newStream(metric model.Metric) *stream { return &stream{ metric: metric, @@ -258,7 +262,7 @@ func (s *memorySeriesStorage) Flush(flushOlderThan time.Time, queue chan<- model s.Lock() for _, fingerprint := range emptySeries { - if len(s.fingerprintToSeries[fingerprint].values) == 0 { + if s.fingerprintToSeries[fingerprint].empty() { s.dropSeries(&fingerprint) } }