- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 39 for resultChan (0.17 sec)
-
staging/src/k8s.io/apiextensions-apiserver/test/integration/registration_test.go
if err != nil { t.Fatalf("unable to create Noxu Instance %q:%v", key, err) } } addEvents := 0 for addEvents < len(instances) { select { case watchEvent := <-noxuNamespacedWatch.ResultChan(): if e, a := watch.Added, watchEvent.Type; e != a { t.Fatalf("expected %v, got %v", e, a) } name, err := meta.NewAccessor().Name(watchEvent.Object) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 14 11:58:05 UTC 2022 - 15.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/watch_test.go
// Send/receive should still work for _, item := range watchTestTable { try(item.t, item.obj) } // Client requests a close ws.Close() select { case data, ok := <-simpleStorage.fakeWatch.ResultChan(): if ok { t.Errorf("expected a closed result channel, but got watch result %#v", data) } case <-time.After(5 * time.Second): t.Errorf("watcher did not close when client closed") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 30 17:27:39 UTC 2023 - 30K bytes - Viewed (0) -
istioctl/pkg/wait/wait.go
default: continue } } return nil }) return g } type watcher struct { resultsChan chan string errorChan chan error ctx context.Context } func withContext(ctx context.Context) *watcher { return &watcher{ resultsChan: make(chan string, 1), errorChan: make(chan error, 1), ctx: ctx, } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 17 12:24:17 UTC 2024 - 10.1K bytes - Viewed (1) -
security/pkg/pki/ra/k8s_ra_test.go
w, _ := client.Kube().CertificatesV1().CertificateSigningRequests().Watch(ctx, metav1.ListOptions{}) go func() { for { select { case <-ctx.Done(): return case r := <-w.ResultChan(): csr := r.Object.(*cert.CertificateSigningRequest).DeepCopy() if csr.Status.Certificate != nil { continue } csr.Status.Certificate = certificate
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Sep 27 00:44:54 UTC 2023 - 9.7K bytes - Viewed (0) -
security/pkg/k8s/chiron/utils.go
}) if err != nil { return nil, fmt.Errorf("failed to watch CSR %v", csr) } // Set a timeout timer := time.After(watchTimeout) for { select { case r := <-watcher.ResultChan(): reqSigned := r.Object.(*cert.CertificateSigningRequest) if reqSigned.Status.Certificate != nil { return reqSigned.Status.Certificate, nil } case <-timer:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 05 18:11:22 UTC 2024 - 9.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0) -
security/pkg/k8s/chiron/utils_test.go
w, _ := client.Kube().CertificatesV1().CertificateSigningRequests().Watch(ctx, metav1.ListOptions{}) go func() { for { select { case <-ctx.Done(): return case r := <-w.ResultChan(): csr := r.Object.(*cert.CertificateSigningRequest).DeepCopy() if csr.Status.Certificate != nil { log.Debugf("test signer skip, already signed: %v", csr.Name) continue }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 03:58:11 UTC 2024 - 13K bytes - Viewed (0) -
pkg/test/kube/util.go
watch, err := secret.Watch(context.TODO(), metav1.ListOptions{}) if err != nil { return nil, fmt.Errorf("failed to set up watch for secret (error: %v)", err) } events := watch.ResultChan() startTime := time.Now() for { select { case event := <-events: secret := event.Object.(*corev1.Secret) if secret.GetName() == name { return secret, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Dec 04 22:47:52 UTC 2023 - 9.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/rest/resttest/resttest.go
t.Errorf("unexpected error: %v, %v", err, action) } if err := emitFn(obj, action); err != nil { t.Errorf("unexpected error: %v", err) } select { case _, ok := <-watcher.ResultChan(): if !ok { t.Errorf("watch channel should be open") } case <-time.After(wait.ForeverTestTimeout): t.Errorf("unexpected timeout from result channel") } watcher.Stop()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 55.8K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_handler_test.go
if err != nil { t.Fatal(err) } // 5 events: delete marker, create v1alpha1, create v1beta1, update v1alpha1, update v1beta1 for i := 0; i < 5; i++ { select { case event, ok := <-watch.ResultChan(): if !ok { t.Fatalf("watch closed") } item, isUnstructured := event.Object.(*unstructured.Unstructured) if !isUnstructured { t.Fatalf("unexpected object type %T: %#v", item, event)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 13 15:27:39 UTC 2023 - 34.6K bytes - Viewed (0)