(w cache.Watcher)
| 55 | func (o testObject) GetResourceVersion() string { return o.resourceVersion } |
| 56 | |
| 57 | func withCounter(w cache.Watcher) (*uint32, cache.Watcher) { |
| 58 | var counter uint32 |
| 59 | return &counter, &cache.ListWatch{ |
| 60 | WatchFunc: func(options metav1.ListOptions) (watch.Interface, error) { |
| 61 | atomic.AddUint32(&counter, 1) |
| 62 | return w.Watch(options) |
| 63 | }, |
| 64 | } |
| 65 | } |
| 66 | |
| 67 | func makeTestEvent(rv int) watch.Event { |
| 68 | return watch.Event{ |
no test coverage detected