github/client-go
1
0
Fork 0
mirror of https://github.com/kubernetes/client-go.git synced 2025-09-09 19:09:30 +00:00
Code Issues Projects Releases Wiki Activity

Correct some wrong syntax

Browse Source 
Signed-off-by: zhoumingcheng <zhoumingcheng@beyondcent.com>

Kubernetes-commit: e590ab77dcb68486a154b755aae658509b9290ea
This commit is contained in:
zhoumingcheng
2022-07-12 10:46:56 +08:00
committed by Kubernetes Publisher
parent 743e29dc1f
commit 84e1219642
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
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