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

Make the benchmark more realistic, returning some postings

Browse source 
Signed-off-by: Marco Pracucci <marco@pracucci.com>
This commit is contained in:
Marco Pracucci 2023-09-28 10:46:22 +02:00
parent 9bcca44ac4
commit 8d92930140
No known key found for this signature in database
GPG key ID: 74C1BD403D2DF9B5
1 changed files with 12 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
tsdb/postings_for_matchers_cache_test.go
View file

@ -340,7 +340,10 @@ func TestPostingsForMatchersCache(t *testing.T) {
} }
func BenchmarkPostingsForMatchersCache(b *testing.B) { func BenchmarkPostingsForMatchersCache(b *testing.B) {
const numMatchers = 100 const (
numMatchers = 100
numPostings = 100
)
var ( var (
ctx = context.Background() ctx = context.Background()
@ -353,11 +356,17 @@ func BenchmarkPostingsForMatchersCache(b *testing.B) {
matchersLists[i] = []*labels.Matcher{labels.MustNewMatcher(labels.MatchEqual, "matchers", fmt.Sprintf("%d", i))} matchersLists[i] = []*labels.Matcher{labels.MustNewMatcher(labels.MatchEqual, "matchers", fmt.Sprintf("%d", i))}
} }
// Create a postings list.
refs := make([]storage.SeriesRef, numPostings)
for r := range refs {
refs[r] = storage.SeriesRef(r)
}
b.Run("no evictions", func(b *testing.B) { b.Run("no evictions", func(b *testing.B) {
// Configure the cache to never evict. // Configure the cache to never evict.
cache := NewPostingsForMatchersCache(time.Hour, 1000000, 1024*1024*1024, true) cache := NewPostingsForMatchersCache(time.Hour, 1000000, 1024*1024*1024, true)
cache.postingsForMatchers = func(ctx context.Context, ix IndexPostingsReader, ms ...*labels.Matcher) (index.Postings, error) { cache.postingsForMatchers = func(ctx context.Context, ix IndexPostingsReader, ms ...*labels.Matcher) (index.Postings, error) {
return index.NewListPostings(nil), nil return index.NewListPostings(refs), nil
} }
b.ResetTimer() b.ResetTimer()
@ -374,7 +383,7 @@ func BenchmarkPostingsForMatchersCache(b *testing.B) {
// Configure the cache to evict continuously. // Configure the cache to evict continuously.
cache := NewPostingsForMatchersCache(time.Hour, 1, 1, true) cache := NewPostingsForMatchersCache(time.Hour, 1, 1, true)
cache.postingsForMatchers = func(ctx context.Context, ix IndexPostingsReader, ms ...*labels.Matcher) (index.Postings, error) { cache.postingsForMatchers = func(ctx context.Context, ix IndexPostingsReader, ms ...*labels.Matcher) (index.Postings, error) {
return index.NewListPostings(nil), nil return index.NewListPostings(refs), nil
} }
b.ResetTimer() b.ResetTimer()