如何在自定义控制器中强制对 SharedIndexInformer 进行完全重新同步

最近发现不少小伙伴都对Golang很感兴趣，所以今天继续给大家介绍Golang相关的知识，本文《如何在自定义控制器中强制对 SharedIndexInformer 进行完全重新同步》主要内容涉及到等等知识点，希望能帮到你！当然如果阅读本文时存在不同想法，可以在评论中表达，但是请勿使用过激的措辞~

我正在 client-go 的帮助下用 Go 为 Kubernetes 编写一个自定义控制器。 它基于示例控制器并且到目前为止运行良好。

SharedIndexInformer 可以选择定期重新同步所有对象。 （参数 resyncPeriod 在示例控制器中设置为 30 秒。）

有办法立即强制重新同步吗？

处理定期重新同步的代码似乎调用了 store.Resync()。 我尝试调用 fooInformer.Informer().GetStore().Resync()。调用成功，但重新同步未发生。我错过了什么？

我使用的是 client-go v0.17.2，服务器是 EKS v1.14.9-eks-c0eccc。

解决方案

这是不可能的。

执行定期重新同步的 cache.store 在 k8s.io/client-go/tools/cache/controller.go 中的 newinformer 中实例化为 cache.deltafifo 队列：

// this will hold incoming changes. note how we pass clientstate in as a
    // keylister, that way resync operations will result in the correct set
    // of update/delete deltas.
    fifo := newdeltafifowithoptions(deltafifooptions{
        knownobjects:          clientstate,
        emitdeltatypereplaced: true,
    })

这是由 cache.new() 作为未导出字段 cache.controller{}.config.queue 返回的，没有用于访问的导出函数 - 因此无法手动调用 resync()。

在调用 fooinformer.informer().getstore().resync() 时，您正在使用在 client-go/tools/cache/store.go 中定义的 store 类型的 resync 函数/方法

我们可以看到以下内容：

在 store 类型定义中：

// resync is meaningless in the terms appearing here but has
// meaning in some implementations that have non-trivial
// additional behavior (e.g., deltafifo).
resync() error

在下面的重新同步定义中：

// Resync is meaningless for one of these
func (c *cache) Resync() error {
return nil
}

除非您实际上有其他类来执行重新同步，否则这实际上应该什么也不做。

这就是为什么

希望有帮助！

到这里，我们也就讲完了《如何在自定义控制器中强制对 SharedIndexInformer 进行完全重新同步》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！