mudhorn/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus.git synced 2025-03-05 20:59:13 -08:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

Fix TestMemSeries_append_atVariableRate

Browse source 
Signed-off-by: Oleg Zaytsev <mail@olegzaytsev.com>
This commit is contained in:
Oleg Zaytsev 2022-04-20 17:50:05 +02:00
parent ac87e2d4d6
commit 9d66af50a8
No known key found for this signature in database
GPG key ID: 7E9FE9FD48F512EF
1 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
tsdb/head_test.go
View file

@ -1323,7 +1323,8 @@ func TestMemSeries_append_atVariableRate(t *testing.T) {
require.NoError(t, chunkDiskMapper.Close()) require.NoError(t, chunkDiskMapper.Close())
}) })
s := newMemSeries(labels.Labels{}, 1, DefaultBlockDuration, nil, defaultIsolationDisabled) lbls := labels.Labels{}
s := newMemSeries(lbls, 1, lbls.Hash(), DefaultBlockDuration, 0, nil, defaultIsolationDisabled)
// At this slow rate, we will fill the chunk in two block durations. // At this slow rate, we will fill the chunk in two block durations.
slowRate := (DefaultBlockDuration * 2) / samplesPerChunk slowRate := (DefaultBlockDuration * 2) / samplesPerChunk
@ -1331,7 +1332,7 @@ func TestMemSeries_append_atVariableRate(t *testing.T) {
var nextTs int64 var nextTs int64
var totalAppendedSamples int var totalAppendedSamples int
for i := 0; i < samplesPerChunk/4; i++ { for i := 0; i < samplesPerChunk/4; i++ {
ok, _ := s.append(nextTs, float64(i), 0, chunkDiskMapper) _, ok, _ := s.append(nextTs, float64(i), 0, chunkDiskMapper)
require.Truef(t, ok, "slow sample %d was not appended", i) require.Truef(t, ok, "slow sample %d was not appended", i)
nextTs += slowRate nextTs += slowRate
totalAppendedSamples++ totalAppendedSamples++
@ -1340,12 +1341,12 @@ func TestMemSeries_append_atVariableRate(t *testing.T) {
// Suddenly, the rate increases and we receive a sample every millisecond. // Suddenly, the rate increases and we receive a sample every millisecond.
for i := 0; i < math.MaxUint16; i++ { for i := 0; i < math.MaxUint16; i++ {
ok, _ := s.append(nextTs, float64(i), 0, chunkDiskMapper) _, ok, _ := s.append(nextTs, float64(i), 0, chunkDiskMapper)
require.Truef(t, ok, "quick sample %d was not appended", i) require.Truef(t, ok, "quick sample %d was not appended", i)
nextTs++ nextTs++
totalAppendedSamples++ totalAppendedSamples++
} }
ok, chunkCreated := s.append(DefaultBlockDuration, float64(0), 0, chunkDiskMapper) _, ok, chunkCreated := s.append(DefaultBlockDuration, float64(0), 0, chunkDiskMapper)
require.True(t, ok, "new chunk sample was not appended") require.True(t, ok, "new chunk sample was not appended")
require.True(t, chunkCreated, "sample at block duration timestamp should create a new chunk") require.True(t, chunkCreated, "sample at block duration timestamp should create a new chunk")