8 Resync机制

8.1 DeltaFIFO队列为什么需要Resync

        为什么需要 Resync 机制呢？因为在处理 SharedInformer 事件回调时，可能存在处理失败的情况，定时的 Resync 让这些处理失败的事件有了重新 onUpdate 处理的机会。

        主要的目的是为了不丢数据，处理 resync 机制还有边缘触发与水平获取的设计，一起来保证不丢事件、数据同步并能及时响应事件。

图来自于《Programming Kubernetes》

8.2 代码实现

8.2.1 Resync

// 重新同步将为每个项目发送一个同步事件
func (f *DeltaFIFO) Resync() error {
  f.lock.Lock()
  defer f.lock.Unlock()

  if f.knownObjects == nil {
    return nil
  }

  // ListKeys返回当前在FIFO中的对象的所有键的列表。
  keys := f.knownObjects.ListKeys()

  for _, k := range keys {
    if err := f.syncKeyLocked(k); err != nil {
      return err
    }

  }

  return nil
}