- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewRaceFreeFake (0.13 sec)
-
staging/src/k8s.io/apimachinery/pkg/watch/watch.go
} // RaceFreeFakeWatcher lets you test anything that consumes a watch.Interface; threadsafe. type RaceFreeFakeWatcher struct { result chan Event Stopped bool sync.Mutex } func NewRaceFreeFake() *RaceFreeFakeWatcher { return &RaceFreeFakeWatcher{ result: make(chan Event, DefaultChanSize), } } // Stop implements Interface.Stop(). func (f *RaceFreeFakeWatcher) Stop() { f.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 20:06:22 UTC 2024 - 8.1K bytes - Viewed (1) -
pkg/controller/volume/persistentvolume/testing/testing.go
// will push added / modified / deleted object. func (r *VolumeReactor) Watch(gvr schema.GroupVersionResource, ns string) (watch.Interface, error) { r.lock.Lock() defer r.lock.Unlock() fakewatcher := watch.NewRaceFreeFake() if _, exists := r.watchers[gvr]; !exists { r.watchers[gvr] = make(map[string][]*watch.RaceFreeFakeWatcher) } r.watchers[gvr][ns] = append(r.watchers[gvr][ns], fakewatcher) return fakewatcher, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 20.1K bytes - Viewed (0) -
pkg/volume/csi/csi_attacher_test.go
t.Run(tc.name, func(t *testing.T) { fakeClient := fakeclient.NewSimpleClientset() plug, tmpDir := newTestPlugin(t, fakeClient) defer os.RemoveAll(tmpDir) fakeWatcher := watch.NewRaceFreeFake() fakeClient.Fake.PrependWatchReactor("volumeattachments", core.DefaultWatchReactor(fakeWatcher, nil)) attacher, err := plug.NewAttacher() if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 58.1K bytes - Viewed (0)