- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for valueWatchers (0.2 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
type indexedWatchers struct { allWatchers map[namespacedName]watchersMap valueWatchers map[string]watchersMap } func (i *indexedWatchers) addWatcher(w *cacheWatcher, number int, scope namespacedName, value string, supported bool) { if supported { if _, ok := i.valueWatchers[value]; !ok { i.valueWatchers[value] = watchersMap{} } i.valueWatchers[value].addWatcher(w, number) } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
cacher.Lock() defer cacher.Unlock() require.Equal(t, expectedWatchersCounter, len(cacher.watchers.allWatchers)) require.Equal(t, expectedValueWatchersCounter, len(cacher.watchers.valueWatchers)) } assertCacherInternalState(0, 0) var forgetWatcherFn func(bool) var forgetCounter int forgetWatcherWrapped := func(drainWatcher bool) { forgetCounter++ forgetWatcherFn(drainWatcher)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0)