- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 39 for resultChan (0.37 sec)
-
cni/pkg/install/cniconfig_test.go
defer cancel() resultChan, errChan := make(chan string, 1), make(chan error, 1) go func(resultChan chan string, errChan chan error, ctx context.Context, cniConfName, mountedCNINetDir string, chained bool) { result, err := getCNIConfigFilepath(ctx, cniConfName, mountedCNINetDir, chained) if err != nil { errChan <- err return } resultChan <- result
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 21 18:32:01 UTC 2024 - 15.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/filter.go
f: f, } go fw.loop() return fw } type filteredWatch struct { incoming Interface result chan Event f FilterFunc } // ResultChan returns a channel which will receive filtered events. func (fw *filteredWatch) ResultChan() <-chan Event { return fw.result } // Stop stops the upstream watch, which will eventually stop this watch. func (fw *filteredWatch) Stop() { fw.incoming.Stop() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 2.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher_test.go
}() // We expect all init events to be delivered. for i := 0; i < numObjects; i++ { <-w.ResultChan() } // We don't expect any other event to be delivered and thus // the ResultChan to be closed. result, ok := <-w.ResultChan() if ok { t.Errorf("unexpected event: %#v", result) } wg.Wait() } func TestTimeBucketWatchersBasic(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 22.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/streamwatcher.go
// error reporting might block forever. // Therefore a dedicated stop channel is used to resolve this blocking. done: make(chan struct{}), } go sw.receive() return sw } // ResultChan implements Interface. func (sw *StreamWatcher) ResultChan() <-chan Event { return sw.result } // Stop implements Interface. func (sw *StreamWatcher) Stop() { // Call Close() exactly once by locking and setting a flag. sw.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 06 13:42:59 UTC 2021 - 3.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
d.RLock() defer d.RUnlock() return d.requestWatchProgressCounter } type dummyWatch struct { ch chan watch.Event } func (w *dummyWatch) ResultChan() <-chan watch.Event { return w.ch } func (w *dummyWatch) Stop() { close(w.ch) } func newDummyWatch() watch.Interface { return &dummyWatch{ ch: make(chan watch.Event), } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/basic_test.go
t.Errorf("expected %v, got %v", e, a) } for watchVersion, noxuWatch := range noxuWatchs { select { case watchEvent := <-noxuWatch.ResultChan(): if e, a := watch.Added, watchEvent.Type; e != a { t.Errorf("expected %v, got %v", e, a) break } createdObjectMeta, err := meta.Accessor(watchEvent.Object) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 23 11:35:33 UTC 2024 - 33.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/mux.go
type broadcasterWatcher struct { result chan Event stopped chan struct{} stop sync.Once id int64 m *Broadcaster } // ResultChan returns a channel to use for waiting on events. func (mw *broadcasterWatcher) ResultChan() <-chan Event { return mw.result } // Stop stops watching and removes mw from its list. // It will block until the watcher stop request is actually executed
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 16 15:26:36 UTC 2022 - 9.4K bytes - Viewed (0) -
pkg/volume/util/recyclerclient/recycler_client.go
case <-stopChannel: return case eventEvent, ok := <-eventWatch.ResultChan(): if !ok { return } eventCh <- eventEvent } } }() go func() { defer podWatch.Stop() defer wg.Done() for { select { case <-stopChannel: return case podEvent, ok := <-podWatch.ResultChan(): if !ok { return } eventCh <- podEvent
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 8.5K bytes - Viewed (1) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/change_test.go
w, err := noxuNamespacedResourceClient.Watch(context.TODO(), metav1.ListOptions{}) if err != nil { t.Errorf("unexpected error establishing watch: %v", err) return } for event := range w.ResultChan() { switch event.Type { case watch.Added, watch.Modified, watch.Deleted: // all expected default: t.Errorf("unexpected watch event: %#v", event) } } }(i) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:59:03 UTC 2024 - 5.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/watch.go
w.WriteHeader(http.StatusOK) flusher.Flush() kind := s.Scope.Kind watchEncoder := newWatchEncoder(req.Context(), kind, s.EmbeddedEncoder, s.Encoder, framer) ch := s.Watching.ResultChan() done := req.Context().Done() for { select { case <-s.ServerShuttingDownCh: // the server has signaled that it is shutting down (not accepting
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 14 16:37:25 UTC 2023 - 11.4K bytes - Viewed (0)