- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for watchCancel (0.1 sec)
-
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)