s.processor.run
r.ShouldResync
fifo := NewDeltaFIFOWithOptions
controller.processLoop
s.processor.handler.OnUpdates.processor.handler.OnAdds.processor.handler.OnDelete
DeltaFIFO
c.config.Queue.Pop(PopProcessFunc(c.config.Process))
r.store.Addr.store.Updater.store.Delete
controller.Run
sharedIndexInformer
s.controller = Controller.New(cfg)
sharedProcessor
listener.add
Delete
r.store.Resync
DeltaFIFO.POP
r.store := c.config.Queue
cfg := &Config
r.listerWatcher.List
s.indexer.Updates.indexer.Add
listener.pop
s.Run
AddedModifiedDeletedBookmark
s.processor.distribute
listener.run
SyncReplacedAddedUpdated
s.onDelete
用户自定义实现
Process := s.HandleDeltas
r.Run
r.ListAndWatch
s.onUpdates.onAdd
s.HandleDeltas
r.listerWatcher.Watch
外部传入
r.watchHandler
r.syncWith
s := NewSharedIndexInformer
Queue
索引更新
r := NewReflector
s.indexer.Delete
r.store.Replace
