Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for watchCancel (0.1 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go

    	if err != nil && apierrors.IsTooManyRequests(err) {
    		t.Errorf("Unexpected 429 error without ResilientWatchCacheInitialization feature for List")
    	}
    
    	watchCtx, watchCancel := context.WithTimeout(context.Background(), 250*time.Millisecond)
    	defer watchCancel()
    
    	_, err = cacher.Watch(watchCtx, "/pods/ns", opts)
    	if err != nil && apierrors.IsTooManyRequests(err) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 82.9K bytes
    - Viewed (0)
Back to top