upstream/kubernetes
1
0
Fork 0
mirror of https://github.com/kubernetes/kubernetes.git synced 2026-06-11 09:53:38 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge pull request #139619 from Jefftree/cacher-init-concurrent-decode-bench

Browse source 
apiserver: exercise ConcurrentWatchObjectDecode on/off in BenchmarkCacherInit
This commit is contained in:
Kubernetes Prow Robot 2026-06-11 00:49:13 +05:30 committed by GitHub
commit 4a1340bfd5
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 22 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

40
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_init_bench_test.go
View file

@ -65,26 +65,30 @@ func BenchmarkCacherInit(b *testing.B) {
}
for _, rangeStream := range []bool{false, true} {
b.Run(fmt.Sprintf("RangeStream=%v", rangeStream), func(b *testing.B) {
featuregatetesting.SetFeatureGateDuringTest(b, utilfeature.DefaultFeatureGate, features.EtcdRangeStream, rangeStream)
for _, concurrentDecode := range []bool{false, true} {
name := fmt.Sprintf("RangeStream=%v/ConcurrentDecode=%v", rangeStream, concurrentDecode)
b.Run(name, func(b *testing.B) {
featuregatetesting.SetFeatureGateDuringTest(b, utilfeature.DefaultFeatureGate, features.EtcdRangeStream, rangeStream)
featuregatetesting.SetFeatureGateDuringTest(b, utilfeature.DefaultFeatureGate, features.ConcurrentWatchObjectDecode, concurrentDecode)
b.ResetTimer()
b.ReportAllocs()
for i := 0; i < b.N; i++ {
cacher, err := NewCacherFromConfig(config)
if err != nil {
b.Fatal(err)
b.ResetTimer()
b.ReportAllocs()
for i := 0; i < b.N; i++ {
cacher, err := NewCacherFromConfig(config)
if err != nil {
b.Fatal(err)
}
if err := cacher.Wait(ctx); err != nil {
b.Fatal(err)
}
b.StopTimer()
cacher.Stop()
etcd3.TestOnlyResetResourceSizeEstimator(etcdStorage)
b.StartTimer()
}
if err := cacher.Wait(ctx); err != nil {
b.Fatal(err)
}
b.StopTimer()
cacher.Stop()
etcd3.TestOnlyResetResourceSizeEstimator(etcdStorage)
b.StartTimer()
}
b.ReportMetric(float64(pods), "pods/cache")
})
b.ReportMetric(float64(pods), "pods/cache")
})
}
}
}