Kubernetes client-go：watch.Interface vs.cache.NewInformer vs.cache.NewSharedIndexInformer？

Question

我需要我的 Go 应用程序来监控 Kubernetes 集群中的一些资源并对它们的变化做出反应。基于大量文章和示例，我似乎找到了一些方法来做到这一点；但是，我对 Kubernetes 比较陌生，而且它们的描述对我来说太复杂了，以至于我仍然无法掌握它们之间的区别——因此，不知道哪个一个使用，这样我就不会得到一些意想不到的行为......具体来说：

1. watch.Interface.ResultChan()——（通过例如rest.Request.Watch()获得）——这似乎已经让我通过提供Added/Modified/Deleted事件对资源发生的变化做出反应；

2. cache.NewInformer() — 当我实现 cache.ResourceEventHandler 时，我可以将它作为最后一个参数传递：

   cache.NewInformer(
           cache.NewListWatchFromClient(clientset.Batch().RESTClient(), "jobs", ...),
           &batchv1.Job{},
           0,
           myHandler)
   

   ——那么，myHandler 对象将收到 OnAdd()/OnUpdate()/OnDelete() 调用。

   对我来说，这似乎或多或少等同于我在上面 (1.​​) 中得到的 ResultChan；一个区别是，显然现在我得到了资源的“之前”状态作为奖励，而使用ResultChan 我只会得到它的“之后”状态。

   另外，IIUC，这实际上以某种方式建立在上面提到的watch.Interface（通过NewListWatchFromClient）之上——所以我想它带来了一些价值，和/或修复了原始@ 的一些（什么？）缺陷987654343@?

3. cache.NewSharedInformer() 和 cache.NewSharedIndexInformer() — _{^{（哇，现在 那些 已经满嘴了……）}} 我试图挖掘 godocs，但我觉得我完全不懂术语，以至于我似乎无法掌握“常规”NewInformer 与NewSharedInformer 与NewSharedIndexInformer 之间的细微差别（？）。 .. ????

有人可以帮我了解 Kubernetes client-go 包中上述 API 之间的区别吗？

Answer 1

这些方法在抽象级别上有所不同。如果更高层次的抽象符合您的需要，您应该使用它，因为许多较低层次的问题已经为您解决了。

Informers 是比 watch 更高级别的抽象，listers 也包括 listers。在大多数用例中，您应该使用任何类型的 Informer，而不是较低级别的抽象。 Informer 内部由 watcher、lister 和 内存缓存 组成。

SharedInformers 在您的告密者之间共享与 API 服务器和其他资源的连接。

SharedIndexInformers为您的数据缓存添加索引，以防您使用更大的数据集。

建议使用 SharedInformers 而不是较低级别的抽象。从相同的 SharedInformerFactory 实例化新的 SharedInformes。 Kubernetes Handbook example中有一个例子

informerFactory := informers.NewSharedInformerFactory(clientset, time.Second*30)

podInformer := informerFactory.Core().V1().Pods()
serviceInformer := informerFactory.Core().V1().Services()

podInformer.Informer().AddEventHandler(
    // add your event handling 
)

// add event handling for serviceInformer

informerFactory.Start(wait.NeverStop)
informerFactory.WaitForCacheSync(wait.NeverStop)