Open rootsongjc opened 4 years ago
s.indexer.Add s.indexer.Update s.indexer.Delete最后都调用了queueActionLocked方法
这里有误,index在初始化sharedInformer初始化时传入的是实现了ThreadSafeStore接口的threadSafeMap,不是queueActionLocked。 queueActionLocked是reflect的watchhandler从apiserver获取增量事件后,放入deltaFifo时调用的,这两个存储搞混了。
https://cloudnative.to/blog/client-go-informer/
这篇文章从Informer的初始化调用链和事件如何流向的角度分析了Informer各个组件。