Add 'loki_ingester_memory_chunks' when recovery from wal

grafana · Sep 10, 2021 · 92ca322 · 92ca322
1 parent ede12d8
commit 92ca322
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/pkg/ingester/recovery.go b/pkg/ingester/recovery.go
@@ -135,6 +135,7 @@ func (r *ingesterRecoverer) Series(series *Series) error {
 		if err != nil {
 			return err
 		}
+		memoryChunks.Add(float64(len(series.Chunks)))
 		r.ing.metrics.recoveredChunksTotal.Add(float64(len(series.Chunks)))
 		r.ing.metrics.recoveredEntriesTotal.Add(float64(entriesAdded))
 		r.ing.replayController.Add(int64(bytesAdded))

diff --git a/pkg/ingester/stream.go b/pkg/ingester/stream.go
@@ -310,7 +310,10 @@ func (s *stream) Push(
 				}
 			}()
 		}
+	}
 
+	if len(s.chunks) != prevNumChunks {
+		memoryChunks.Add(float64(len(s.chunks) - prevNumChunks))
 	}
 
 	if len(failedEntriesWithError) > 0 {
@@ -345,9 +348,6 @@ func (s *stream) Push(
 		return bytesAdded, httpgrpc.Errorf(statusCode, buf.String())
 	}
 
-	if len(s.chunks) != prevNumChunks {
-		memoryChunks.Add(float64(len(s.chunks) - prevNumChunks))
-	}
 	return bytesAdded, nil
 }