github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-06 02:34:03 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #111080 from zhoumingcheng/master-v3

Browse Source 
Correct wrong syntax
This commit is contained in:
Kubernetes Prow Robot 2022-07-14 14:37:08 -07:00 committed by GitHub
commit 3b4d2a9b31
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
staging/src/k8s.io/client-go/rest/request_test.go
View File

@ -2592,7 +2592,7 @@ func TestRequestWatchRetryWithRateLimiterBackoffAndMetrics(t *testing.T) {
testRetryWithRateLimiterBackoffAndMetrics(t, "Watch", func(ctx context.Context, r *Request) { testRetryWithRateLimiterBackoffAndMetrics(t, "Watch", func(ctx context.Context, r *Request) {
w, err := r.Watch(ctx) w, err := r.Watch(ctx)
if err == nil { if err == nil {
// in this test the the response body returned by the server is always empty, // in this test the response body returned by the server is always empty,
// this will cause StreamWatcher.receive() to: // this will cause StreamWatcher.receive() to:
// - return an io.EOF to indicate that the watch closed normally and // - return an io.EOF to indicate that the watch closed normally and
// - then close the io.Reader // - then close the io.Reader
@ -2620,7 +2620,7 @@ func TestRequestWatchWithRetryInvokeOrder(t *testing.T) {
testWithRetryInvokeOrder(t, "Watch", func(ctx context.Context, r *Request) { testWithRetryInvokeOrder(t, "Watch", func(ctx context.Context, r *Request) {
w, err := r.Watch(ctx) w, err := r.Watch(ctx)
if err == nil { if err == nil {
// in this test the the response body returned by the server is always empty, // in this test the response body returned by the server is always empty,
// this will cause StreamWatcher.receive() to: // this will cause StreamWatcher.receive() to:
// - return an io.EOF to indicate that the watch closed normally and // - return an io.EOF to indicate that the watch closed normally and
// - then close the io.Reader // - then close the io.Reader
@ -2635,7 +2635,7 @@ func TestRequestWatchWithWrapPreviousError(t *testing.T) {
testWithWrapPreviousError(t, func(ctx context.Context, r *Request) error { testWithWrapPreviousError(t, func(ctx context.Context, r *Request) error {
w, err := r.Watch(ctx) w, err := r.Watch(ctx)
if err == nil { if err == nil {
// in this test the the response body returned by the server is always empty, // in this test the response body returned by the server is always empty,
// this will cause StreamWatcher.receive() to: // this will cause StreamWatcher.receive() to:
// - return an io.EOF to indicate that the watch closed normally and // - return an io.EOF to indicate that the watch closed normally and
// - then close the io.Reader // - then close the io.Reader