登录
首页 >  Golang >  Go问答

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

来源:stackoverflow

时间:2024-04-06 20:09:42 492浏览 收藏

最近发现不少小伙伴都对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.storek8s.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学习网公众号,带你了解更多关于的知识点!

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>