From 69eddc9e8437f127f4891511481fd20ef4f37a29 Mon Sep 17 00:00:00 2001 From: beorn7 Date: Mon, 8 May 2017 18:20:23 +0200 Subject: [PATCH] storage: Correctly increase prometheus_local_storage_open_head_chunks --- storage/local/storage.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/storage/local/storage.go b/storage/local/storage.go index 4dd27cb78..fdf0a8f8a 100644 --- a/storage/local/storage.go +++ b/storage/local/storage.go @@ -927,6 +927,7 @@ func (s *MemorySeriesStorage) Append(sample *model.Sample) error { s.discardedSamples.WithLabelValues(outOfOrderTimestamp).Inc() return ErrOutOfOrderSample // Caused by the caller. } + headChunkWasClosed := series.headChunkClosed completedChunksCount, err := series.add(model.SamplePair{ Value: sample.Value, Timestamp: sample.Timestamp, @@ -935,6 +936,11 @@ func (s *MemorySeriesStorage) Append(sample *model.Sample) error { s.quarantineSeries(fp, sample.Metric, err) return err } + if headChunkWasClosed { + // Appending to a series with a closed head chunk creates an + // additional open head chunk. + s.headChunks.Inc() + } s.ingestedSamples.Inc() s.incNumChunksToPersist(completedChunksCount)