- Sort Score
- Result 10 results
- Languages All
Results 31 - 39 of 39 for resultChan (1.06 sec)
-
staging/src/k8s.io/apiextensions-apiserver/test/integration/fixtures/resources.go
metav1.ListOptions{ResourceVersion: createdInstance.GetResourceVersion()}) if err != nil { return false, err } defer noxuWatch.Stop() select { case watchEvent := <-noxuWatch.ResultChan(): if watch.Error == watchEvent.Type { return false, nil } if watch.Deleted != watchEvent.Type { return false, fmt.Errorf("expected DELETE, but got %#v", watchEvent) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 19 02:01:40 UTC 2021 - 21.4K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/defaulting_test.go
w, err := fooClient.Watch(context.TODO(), metav1.ListOptions{ResourceVersion: initialResourceVersion}) if err != nil { t.Fatal(err) } select { case event := <-w.ResultChan(): if event.Type != watch.Modified { t.Fatalf("unexpected watch event: %v, %#v", event.Type, event.Object) } if e, a := "v1beta1", event.Object.GetObjectKind().GroupVersionKind().Version; e != a {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 06 05:32:34 UTC 2023 - 21.2K bytes - Viewed (0) -
src/net/http/httputil/reverseproxy_test.go
} type result struct { before, after string } resultChan := make(chan result, 1) proxyHandler := NewSingleHostReverseProxy(backendURL) frontend := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { before := r.URL.String() proxyHandler.ServeHTTP(w, r) after := r.URL.String() resultChan <- result{before: before, after: after} })) defer frontend.Close()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 54.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 12:22:41 UTC 2023 - 18.7K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/fieldselector_test.go
} else { t.Fatalf("Timed out waiting for watch events, expected added: %v, removed: %v, but got added: %v, removed: %v", tc.expectedByName, tc.expectObserveRemoval, added, deleted) } case event := <-w.ResultChan(): obj, err := meta.Accessor(event.Object) if err != nil { t.Fatal(err) } switch event.Type { case watch.Added: added.Insert(obj.GetName()) case watch.Deleted:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 15:53:03 UTC 2024 - 27K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
pkg/volume/csi/csi_attacher.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 03 07:38:14 UTC 2023 - 25.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go
if _, err := registry.DeleteCollection(testContext, rest.ValidateAllObjectFunc, nil, &metainternalversion.ListOptions{}); err != nil { t.Fatalf("Unexpected error: %v", err) } got, open := <-watcher.ResultChan() if !open { t.Errorf("Unexpected channel close") } else { if got.Type != "DELETED" { t.Errorf("Unexpected event type: %s", got.Type) } gotObject := got.Object.(*example.Pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 101.8K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/resource/builder_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 11:58:41 UTC 2023 - 56.1K bytes - Viewed (0)