mirrors/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus.git synced 2025-08-06 22:27:17 +02:00
Code Issues Projects Releases Wiki Activity

add numHistogramSamples to block stats

Browse Source 
Signed-off-by: Ahmed Hassan <afayekhassan@gmail.com>
This commit is contained in:
Ahmed Hassan 2025-07-02 17:15:50 -07:00
parent 74aca682b7
commit 6d77b47d13
3 changed files with 14 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
tsdb/block.go
View File

@ -188,10 +188,11 @@ type BlockMeta struct {
// BlockStats contains stats about contents of a block. // BlockStats contains stats about contents of a block.
type BlockStats struct { type BlockStats struct {
NumSamples uint64 `json:"numSamples,omitempty"` NumSamples uint64 `json:"numSamples,omitempty"`
NumSeries uint64 `json:"numSeries,omitempty"` NumHistogramSamples uint64 `json:"numHistogramSamples,omitempty"`
NumChunks uint64 `json:"numChunks,omitempty"` NumSeries uint64 `json:"numSeries,omitempty"`
NumTombstones uint64 `json:"numTombstones,omitempty"` NumChunks uint64 `json:"numChunks,omitempty"`
NumTombstones uint64 `json:"numTombstones,omitempty"`
} }
// BlockDesc describes a block by ULID and time range. // BlockDesc describes a block by ULID and time range.

4
tsdb/compact.go
View File

@ -896,6 +896,10 @@ func (c DefaultBlockPopulator) PopulateBlock(ctx context.Context, metrics *Compa
meta.Stats.NumSeries++ meta.Stats.NumSeries++
for _, chk := range chks { for _, chk := range chks {
meta.Stats.NumSamples += uint64(chk.Chunk.NumSamples()) meta.Stats.NumSamples += uint64(chk.Chunk.NumSamples())
enc := chk.Chunk.Encoding()
if enc == chunkenc.EncHistogram || enc == chunkenc.EncFloatHistogram {
meta.Stats.NumHistogramSamples += uint64(chk.Chunk.NumSamples())
}
} }
for _, chk := range chks { for _, chk := range chks {

5
tsdb/compact_test.go
View File

@ -1098,6 +1098,11 @@ func TestCompaction_populateBlock(t *testing.T) {
s.NumChunks += uint64(len(series.chunks)) s.NumChunks += uint64(len(series.chunks))
for _, chk := range series.chunks { for _, chk := range series.chunks {
s.NumSamples += uint64(len(chk)) s.NumSamples += uint64(len(chk))
for _, smpl := range chk {
if smpl.h != nil || smpl.fh != nil {
s.NumHistogramSamples++
}
}
} }
} }
require.Equal(t, s, meta.Stats) require.Equal(t, s, meta.Stats)