mirror of
https://github.com/kubernetes/client-go.git
synced 2025-06-30 00:41:53 +00:00
Merge pull request #79480 from wojtek-t/fix_clientgo_benchmark
Fix client-go request benchmark Kubernetes-commit: 4b3987d0c390fbac65df5c0a1cf7f89d6ddfc6ce
This commit is contained in:
commit
d1d42e472f
@ -1440,15 +1440,20 @@ func BenchmarkCheckRetryClosesBody(b *testing.B) {
|
||||
defer testServer.Close()
|
||||
|
||||
c := testRESTClient(b, testServer)
|
||||
r := c.Verb("POST").
|
||||
Prefix("foo", "bar").
|
||||
Suffix("baz").
|
||||
Timeout(time.Second).
|
||||
Body([]byte(strings.Repeat("abcd", 1000)))
|
||||
|
||||
requests := make([]*Request, 0, b.N)
|
||||
for i := 0; i < b.N; i++ {
|
||||
if _, err := r.DoRaw(); err != nil {
|
||||
b.Fatalf("Unexpected error: %v %#v", err, err)
|
||||
requests = append(requests, c.Verb("POST").
|
||||
Prefix("foo", "bar").
|
||||
Suffix("baz").
|
||||
Timeout(time.Second).
|
||||
Body([]byte(strings.Repeat("abcd", 1000))))
|
||||
}
|
||||
|
||||
b.ResetTimer()
|
||||
for i := 0; i < b.N; i++ {
|
||||
if _, err := requests[i].DoRaw(); err != nil {
|
||||
b.Fatalf("Unexpected error (%d/%d): %v", i, b.N, err)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user