go - 如何强制对自定义 Controller 中的 SharedIndexInformer 进行完全重新同步

Question

我正在 client-go 的帮助下在 Go 中为 Kubernetes 编写一个自定义 Controller 。
它基于 sample-controller 并且到目前为止运行良好。
SharedIndexInformer 可以选择定期重新同步所有对象。 ( Parameter resyncPeriod 在 sample-controller 中设置为 30 秒。)

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

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

我正在使用 client-go v0.17.2 并且服务器是 EKS v1.14.9-eks-c0eccc 。

Answer 1

这不可能。
执行定期重新同步的 cache.Store 在 newInformer 中的 k8s.io/client-go/tools/cache/controller.go 中实例化为 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() 。