From 5ed8f6c205f70fb0cbb650e5bd413c6f9d0889af Mon Sep 17 00:00:00 2001 From: beorn7 Date: Wed, 4 Mar 2015 18:46:16 +0100 Subject: [PATCH] Update persistQueueLength after chunks were persisted. --- storage/local/storage.go | 1 + 1 file changed, 1 insertion(+) diff --git a/storage/local/storage.go b/storage/local/storage.go index a18f92aca..bbf180f35 100644 --- a/storage/local/storage.go +++ b/storage/local/storage.go @@ -586,6 +586,7 @@ func (s *memorySeriesStorage) handlePersistQueue() { return } chunkCount -= len(cds) + s.persistQueueLength.Set(float64(chunkCount)) } loop: