- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for RunTestWatcherTimeout (0.26 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
if ok { t.Error("ResultChan() should be closed") } case <-time.After(wait.ForeverTestTimeout): t.Errorf("timeout after %v", wait.ForeverTestTimeout) } } func RunTestWatcherTimeout(ctx context.Context, t *testing.T, store storage.Interface) { // initialRV is used to initate the watcher at the beginning of the world. podList := example.PodList{} options := storage.ListOptions{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0)