mirrors/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus.git synced 2026-05-04 20:06:12 +02:00
Code Issues Projects Releases Wiki Activity

test(chunkenc): test that appender can contonue chunks

Browse Source 
Test that initializing a chunk appender from an existing chunk
works correctly.

Signed-off-by: György Krajcsovits <gyorgy.krajcsovits@grafana.com>
This commit is contained in:
György Krajcsovits 2026-02-06 15:33:05 +01:00
parent de4a24325e
commit 07c543f02d
No known key found for this signature in database
GPG Key ID: 47A8F9CE80FD7C7F
1 changed files with 37 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
tsdb/chunkenc/st_helper_test.go
View File

@ -65,20 +65,46 @@ func testChunkSTHandling(t *testing.T, vt ValueType, chunkFactory func() Chunk)
chunk := chunkFactory()
app, err := chunk.Appender()
require.NoError(t, err)
for _, s := range samples {
var clone []byte
for i, s := range samples {
if i == len(samples)-1 {
clone = append(clone, chunk.Bytes()...)
}
sampleAppend(app, vt, s.st, s.t, s.v)
}
require.Equal(t, len(samples), chunk.NumSamples())
it := chunk.Iterator(nil)
for i, s := range samples {
require.Equal(t, vt, it.Next(), "%d: value type mismatch", i)
st, ts, f := get(it, vt)
require.Equal(t, s.t, ts, "%d: timestamp mismatch", i)
require.Equal(t, s.st, st, "%d: start time mismatch", i)
require.InDelta(t, s.v, f, 1e-9, "%d: value mismatch", i)
chunksToTest := []Chunk{chunk}
if len(samples) > 0 {
// If there are samples, also test that appending to a chunk cloned from the original chunk works correctly.
// This tests resuming the appender from a previous chunk.
cloneChunk := chunkFactory()
cloneChunk.Reset(clone)
cloneApp, err := cloneChunk.Appender()
require.NoError(t, err)
sampleAppend(cloneApp, vt, samples[len(samples)-1].st, samples[len(samples)-1].t, samples[len(samples)-1].v)
chunksToTest = append(chunksToTest, cloneChunk)
}
printChunkName := func(i int) string {
if i == 0 {
return "original"
}
return "cloned"
}
for ci, chk := range chunksToTest {
require.Equal(t, len(samples), chk.NumSamples(), "%s chunk: number of samples mismatch", printChunkName(ci))
it := chk.Iterator(nil)
for i, s := range samples {
require.Equal(t, vt, it.Next(), "%s[%d]: value type mismatch", printChunkName(ci), i)
st, ts, f := get(it, vt)
require.Equal(t, s.t, ts, "%s[%d]: timestamp mismatch", printChunkName(ci), i)
require.Equal(t, s.st, st, "%s[%d]: start time mismatch", printChunkName(ci), i)
require.InDelta(t, s.v, f, 1e-9, "%s[%d]: value mismatch", printChunkName(ci), i)
}
require.Equal(t, ValNone, it.Next())
require.NoError(t, it.Err())
}
require.Equal(t, ValNone, it.Next())
require.NoError(t, it.Err())
}
t.Run("manual for debugging", func(t *testing.T) {