- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 59 for ForeverTestTimeout (0.2 sec)
-
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/decorated_watcher_test.go
// expect the decorated channel to be closed select { case e, ok := <-dw.ResultChan(): if ok { t.Errorf("expected result chan closed, got %#v", e) } case <-time.After(wait.ForeverTestTimeout): t.Errorf("timeout after %v", wait.ForeverTestTimeout) } // expect the underlying watcher to have been stopped as a result of the context cancellation if !w.IsStopped() { t.Errorf("expected underlying watcher to be stopped") } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 02 19:25:31 UTC 2021 - 3.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/utils.go
select { case res := <-w.ResultChan(): if res.Type != expectEventType { t.Errorf("event type want=%v, get=%v", expectEventType, res.Type) } case <-time.After(wait.ForeverTestTimeout): t.Errorf("time out after waiting %v on ResultChan", wait.ForeverTestTimeout) } } func testCheckResult(t *testing.T, w watch.Interface, expectEvent watch.Event) { testCheckResultFunc(t, w, func(actualEvent watch.Event) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 22 07:26:55 UTC 2024 - 10.3K bytes - Viewed (1) -
staging/src/k8s.io/apiserver/plugin/pkg/audit/buffered/buffered_test.go
events[i] = &auditinternal.Event{} } return events } func testBatchConfig() BatchConfig { return BatchConfig{ BufferSize: 100, MaxBatchSize: 10, MaxBatchWait: wait.ForeverTestTimeout, ThrottleEnable: false, AsyncDelegate: true, } } func TestBatchedBackendCollectEvents(t *testing.T) { config := testBatchConfig() batchSize := config.MaxBatchSize
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 14 17:20:35 UTC 2018 - 5.9K bytes - Viewed (0) -
pkg/probe/http/http_test.go
require.NoError(t, err) req, err := NewProbeRequest(target, nil) require.NoError(t, err) result, _, _ := prober.Probe(req, wait.ForeverTestTimeout) assert.Equal(t, test.expectLocalResult, result) }) t.Run(desc+"-nonlocal", func(t *testing.T) { followNonLocalRedirects := true prober := New(followNonLocalRedirects)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 18 01:40:08 UTC 2023 - 15.7K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/change_test.go
updateCRD() drained := make(chan struct{}) go func() { defer close(drained) wg.Wait() }() select { case <-drained: case <-time.After(wait.ForeverTestTimeout): t.Fatal("timed out waiting for watchers to be terminated") } stopChan := make(chan struct{}) // Set up loop to modify CRD in the background wg.Add(1) go func() { defer wg.Done()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:59:03 UTC 2024 - 5.2K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_test.go
err := wait.Poll(10*time.Millisecond, wait.ForeverTestTimeout, func() (bool, error) { return len(ctrl.claims.ListKeys()) == 0, nil }) if err != nil { return err } // wait for volume delete operation to appear once volumeWorker() runs return wait.PollImmediate(10*time.Millisecond, wait.ForeverTestTimeout, func() (bool, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 43.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/testing/v2/kms_plugin_mock.go
func waitForBase64PluginToBeUp(plugin *Base64Plugin) error { var gRPCErr error var resp *kmsapi.StatusResponse pollErr := wait.PollImmediate(1*time.Second, wait.ForeverTestTimeout, func() (bool, error) { resp, gRPCErr = plugin.Status(context.Background(), &kmsapi.StatusRequest{}) return gRPCErr == nil && resp.Healthz == "ok", nil }) if pollErr != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 21 19:25:52 UTC 2023 - 6.5K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/defaulting_test.go
addDefault("v1beta2", "c", "C") t.Logf("wait until GET sees 'c' in both status and spec") if err := wait.PollImmediate(100*time.Millisecond, wait.ForeverTestTimeout, func() (bool, error) { obj, err := fooClient.Get(context.TODO(), foo.GetName(), metav1.GetOptions{}) if err != nil { return false, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 06 05:32:34 UTC 2023 - 21.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtranslator_test.go
go func() { // Start the streaming on the WebSocket "exec" client. errorChan <- exec.StreamWithContext(context.Background(), *options) }() select { case <-time.After(wait.ForeverTestTimeout): t.Fatalf("expect stream to be closed after connection is closed.") case err := <-errorChan: if err != nil { t.Errorf("unexpected error: %v", err) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 27 23:21:55 UTC 2024 - 36.4K bytes - Viewed (0) -
pkg/proxy/config/api_test.go
epsConfig.RegisterEventHandler(epsHandler) stopCh := make(chan struct{}) defer close(stopCh) sharedInformers.Start(stopCh) err := wait.PollImmediate(time.Millisecond*10, wait.ForeverTestTimeout, func() (bool, error) { svcHandler.lock.Lock() defer svcHandler.lock.Unlock() if reflect.DeepEqual(svcHandler.state, expectedSvcState) { return true, nil } return false, nil })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 8.2K bytes - Viewed (0)