Added BenchmarkQueryRange
This commit is contained in:
parent
4520e12440
commit
bedc0eda1f
|
@ -19,6 +19,7 @@ import (
|
||||||
"math"
|
"math"
|
||||||
"math/rand"
|
"math/rand"
|
||||||
"os"
|
"os"
|
||||||
|
"strconv"
|
||||||
"testing"
|
"testing"
|
||||||
"testing/quick"
|
"testing/quick"
|
||||||
"time"
|
"time"
|
||||||
|
@ -469,6 +470,38 @@ func BenchmarkLabelMatching(b *testing.B) {
|
||||||
b.StopTimer()
|
b.StopTimer()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func BenchmarkQueryRange(b *testing.B) {
|
||||||
|
now := model.Now()
|
||||||
|
insertStart := now.Add(-2 * time.Hour)
|
||||||
|
|
||||||
|
s, closer := NewTestStorage(b, 2)
|
||||||
|
defer closer.Close()
|
||||||
|
|
||||||
|
// Stop maintenance loop to prevent actual purging.
|
||||||
|
close(s.loopStopping)
|
||||||
|
<-s.loopStopped
|
||||||
|
<-s.logThrottlingStopped
|
||||||
|
// Recreate channel to avoid panic when we really shut down.
|
||||||
|
s.loopStopping = make(chan struct{})
|
||||||
|
|
||||||
|
for i := 0; i < 8192; i++ {
|
||||||
|
s.Append(&model.Sample{
|
||||||
|
Metric: model.Metric{"__name__": model.LabelValue(strconv.Itoa(i)), "job": "test"},
|
||||||
|
Timestamp: insertStart,
|
||||||
|
Value: 1,
|
||||||
|
})
|
||||||
|
}
|
||||||
|
s.WaitForIndexing()
|
||||||
|
|
||||||
|
b.ResetTimer()
|
||||||
|
b.RunParallel(func(pb *testing.PB) {
|
||||||
|
lm, _ := metric.NewLabelMatcher(metric.Equal, "job", "test")
|
||||||
|
for pb.Next() {
|
||||||
|
s.QueryRange(context.Background(), insertStart, now, lm)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
func TestRetentionCutoff(t *testing.T) {
|
func TestRetentionCutoff(t *testing.T) {
|
||||||
now := model.Now()
|
now := model.Now()
|
||||||
insertStart := now.Add(-2 * time.Hour)
|
insertStart := now.Add(-2 * time.Hour)
|
||||||
|
|
Loading…
Reference in New Issue