upstream/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus.git synced 2026-02-18 18:25:24 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions 7

Add cases with jitter in the start time as well

Browse source 
Signed-off-by: György Krajcsovits <gyorgy.krajcsovits@grafana.com>
This commit is contained in:
György Krajcsovits 2026-02-07 16:10:26 +01:00
parent 411eb36b13
commit 49c99fe7f0
No known key found for this signature in database
GPG key ID: 47A8F9CE80FD7C7F
1 changed files with 42 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

43
tsdb/chunkenc/benchmark_test.go
View file

@ -50,7 +50,7 @@ func foreachFmtSampleCase(b *testing.B, fn func(b *testing.B, f fmtCase, s sampl
initST = timestamp.FromTime(d) // Use realistic timestamp.
initT = initST + 15000 // 15s after initST.
initV = 1243535.123
rInts = make([]int64, nSamples)
rInts = make([]int64, 2*nSamples) // Random ints for timestamps and STs.
rFloats = make([]float64, nSamples)
)
@ -58,6 +58,7 @@ func foreachFmtSampleCase(b *testing.B, fn func(b *testing.B, f fmtCase, s sampl
// the generated samples.
for i := range nSamples {
rInts[i] = int64(r.Intn(100))
rInts[nSamples+i] = int64(r.Intn(100))
rFloats[i] = float64(r.Intn(100))
}
@ -125,6 +126,20 @@ func foreachFmtSampleCase(b *testing.B, fn func(b *testing.B, f fmtCase, s sampl
return ret
}(),
},
{
// Delta simulates delta type or worst case for cumulatives, where ST
// is changing on every sample.
name: "vt=constant/st=delta-jitter",
samples: func() (ret []triple) {
t, v := initT, initV
for i := range nSamples {
st := t + rInts[nSamples+i] // ST is the same as the previous t + jitter of up to 100ms.
t += 15000
ret = append(ret, triple{st: st, t: t, v: v})
}
return ret
}(),
},
{
name: "vt=random steps/st=0",
samples: func() (ret []triple) {
@ -187,6 +202,19 @@ func foreachFmtSampleCase(b *testing.B, fn func(b *testing.B, f fmtCase, s sampl
return ret
}(),
},
{
name: "vt=random steps/st=delta-jittery",
samples: func() (ret []triple) {
t, v := initT, initV
for i := range nSamples {
st := t + rInts[nSamples+i] // ST is equal to the previous t + jitter of up to 100ms.
t += rInts[i] - 50 + 15000 // 15 seconds +- up to 100ms of jitter.
v += rFloats[i] - 50 // Varying from -50 to +50 in 100 discrete steps.
ret = append(ret, triple{st: st, t: t, v: v})
}
return ret
}(),
},
{
name: "vt=random 0-1/st=0",
samples: func() (ret []triple) {
@ -294,6 +322,19 @@ func foreachFmtSampleCase(b *testing.B, fn func(b *testing.B, f fmtCase, s sampl
return ret
}(),
},
{
name: "vt=random 0-1/st=delta-jittery",
samples: func() (ret []triple) {
t, v := initT, initV
for i := range nSamples {
st := t + rInts[nSamples+i] // ST is equal to the previous t + jitter of up to 100ms.
t += rInts[i] - 50 + 15000 // 15 seconds +- up to 100ms of jitter.
v += rFloats[i] / 100.0 // Random between 0 and 1.0.
ret = append(ret, triple{st: st, t: t, v: v})
}
return ret
}(),
},
}
for _, f := range []fmtCase{