mirror of
https://github.com/kubernetes/client-go.git
synced 2025-09-09 19:09:30 +00:00
Fix client-go request benchmark
Kubernetes-commit: 85763127c0b9399e6c48ec144c4716543a6cbe2d
This commit is contained in:
committed by
Kubernetes Publisher
parent
bf9edae4fc
commit
deab738de6
@@ -1440,15 +1440,20 @@ func BenchmarkCheckRetryClosesBody(b *testing.B) {
|
|||||||
defer testServer.Close()
|
defer testServer.Close()
|
||||||
|
|
||||||
c := testRESTClient(b, testServer)
|
c := testRESTClient(b, testServer)
|
||||||
r := c.Verb("POST").
|
|
||||||
|
requests := make([]*Request, 0, b.N)
|
||||||
|
for i := 0; i < b.N; i++ {
|
||||||
|
requests = append(requests, c.Verb("POST").
|
||||||
Prefix("foo", "bar").
|
Prefix("foo", "bar").
|
||||||
Suffix("baz").
|
Suffix("baz").
|
||||||
Timeout(time.Second).
|
Timeout(time.Second).
|
||||||
Body([]byte(strings.Repeat("abcd", 1000)))
|
Body([]byte(strings.Repeat("abcd", 1000))))
|
||||||
|
}
|
||||||
|
|
||||||
|
b.ResetTimer()
|
||||||
for i := 0; i < b.N; i++ {
|
for i := 0; i < b.N; i++ {
|
||||||
if _, err := r.DoRaw(); err != nil {
|
if _, err := requests[i].DoRaw(); err != nil {
|
||||||
b.Fatalf("Unexpected error: %v %#v", err, err)
|
b.Fatalf("Unexpected error (%d/%d): %v", i, b.N, err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user