Add 'loki_ingester_memory_chunks' when recovery from wal (#4272)

pull/4396/head
Hiroki Sakamoto 4 years ago committed by GitHub
parent 895165f770
commit 502750deca
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 1
      pkg/ingester/recovery.go
  2. 6
      pkg/ingester/stream.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))

@ -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
}

Loading…
Cancel
Save