mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-24 20:24:09 +00:00
Correct some wrong syntax
Signed-off-by: zhoumingcheng <zhoumingcheng@beyondcent.com>
This commit is contained in:
parent
15f111f78f
commit
e590ab77dc
@ -2564,7 +2564,7 @@ func TestRequestWatchWithRetry(t *testing.T) {
|
|||||||
testRequestWithRetry(t, "Watch", func(ctx context.Context, r *Request) {
|
testRequestWithRetry(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
|
||||||
@ -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
|
||||||
|
Loading…
Reference in New Issue
Block a user