| 178 | } |
| 179 | |
| 180 | type sharedIndexInformer struct { |
| 181 | indexer Indexer |
| 182 | controller Controller |
| 183 | |
| 184 | processor *sharedProcessor |
| 185 | cacheMutationDetector CacheMutationDetector |
| 186 | |
| 187 | // This block is tracked to handle late initialization of the controller |
| 188 | listerWatcher ListerWatcher |
| 189 | objectType runtime.Object |
| 190 | |
| 191 | // resyncCheckPeriod is how often we want the reflector's resync timer to fire so it can call |
| 192 | // shouldResync to check if any of our listeners need a resync. |
| 193 | resyncCheckPeriod time.Duration |
| 194 | // defaultEventHandlerResyncPeriod is the default resync period for any handlers added via |
| 195 | // AddEventHandler (i.e. they don't specify one and just want to use the shared informer's default |
| 196 | // value). |
| 197 | defaultEventHandlerResyncPeriod time.Duration |
| 198 | // clock allows for testability |
| 199 | clock clock.Clock |
| 200 | |
| 201 | started, stopped bool |
| 202 | startedLock sync.Mutex |
| 203 | |
| 204 | // blockDeltas gives a way to stop all event distribution so that a late event handler |
| 205 | // can safely join the shared informer. |
| 206 | blockDeltas sync.Mutex |
| 207 | } |
| 208 | |
| 209 | // dummyController hides the fact that a SharedInformer is different from a dedicated one |
| 210 | // where a caller can `Run`. The run method is disconnected in this case, because higher |
nothing calls this directly
no outgoing calls
no test coverage detected