diff --git a/pkg/endpoints/apiserver_test.go b/pkg/endpoints/apiserver_test.go index f8b393fc7..15855d18f 100644 --- a/pkg/endpoints/apiserver_test.go +++ b/pkg/endpoints/apiserver_test.go @@ -356,11 +356,7 @@ type SimpleRESTStorage struct { requestedResourceVersion string requestedResourceNamespace string - // The id requested, and location to return for ResourceLocation - requestedResourceLocationID string - resourceLocation *url.URL - resourceLocationTransport http.RoundTripper - expectedResourceNamespace string + expectedResourceNamespace string // If non-nil, called inside the WorkFunc when answering update, delete, create. // obj receives the original input to the update, delete, or create call. diff --git a/pkg/endpoints/watch_test.go b/pkg/endpoints/watch_test.go index 998888c77..c5cce9ff8 100644 --- a/pkg/endpoints/watch_test.go +++ b/pkg/endpoints/watch_test.go @@ -922,7 +922,7 @@ func runWatchHTTPBenchmark(b *testing.B, items []example.Pod) { go func() { defer response.Body.Close() if _, err := io.Copy(ioutil.Discard, response.Body); err != nil { - b.Fatal(err) + b.Error(err) } wg.Done() }() @@ -962,7 +962,7 @@ func BenchmarkWatchWebsocket(b *testing.B) { go func() { defer ws.Close() if _, err := io.Copy(ioutil.Discard, ws); err != nil { - b.Fatal(err) + b.Error(err) } wg.Done() }() @@ -1011,7 +1011,7 @@ func BenchmarkWatchProtobuf(b *testing.B) { go func() { defer response.Body.Close() if _, err := io.Copy(ioutil.Discard, response.Body); err != nil { - b.Fatal(err) + b.Error(err) } wg.Done() }()