- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for sendWatchCacheEvent (0.15 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher.go
updateResourceVersion(oldObj, c.versioner, event.ResourceVersion) return &watch.Event{Type: watch.Deleted, Object: oldObj} } return nil } // NOTE: sendWatchCacheEvent is assumed to not modify <event> !!! func (c *cacheWatcher) sendWatchCacheEvent(event *watchCacheEvent) { watchEvent := c.convertToWatchEvent(event) if watchEvent == nil { // Watcher is not interested in that object. return }
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/apiserver/pkg/storage/cacher/cache_watcher_test.go
lock.RLock() defer lock.RUnlock() return count == 2, nil }); err != nil { t.Fatalf("expected forget() to be called twice, because sendWatchCacheEvent should not be blocked by the result channel: %v", err) } } func TestCacheWatcherHandlesFiltering(t *testing.T) { filter := func(_ string, _ labels.Set, field fields.Set) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 22.9K bytes - Viewed (0)