MCPcopy
hub / github.com/kubernetes/client-go / Resync

Method Resync

tools/cache/delta_fifo.go:525–540  ·  view source on GitHub ↗

Resync will send a sync event for each item

()

Source from the content-addressed store, hash-verified

523
524// Resync will send a sync event for each item
525func (f *DeltaFIFO) Resync() error {
526 f.lock.Lock()
527 defer f.lock.Unlock()
528
529 if f.knownObjects == nil {
530 return nil
531 }
532
533 keys := f.knownObjects.ListKeys()
534 for _, k := range keys {
535 if err := f.syncKeyLocked(k); err != nil {
536 return err
537 }
538 }
539 return nil
540}
541
542func (f *DeltaFIFO) syncKey(key string) error {
543 f.lock.Lock()

Callers 2

Calls 2

syncKeyLockedMethod · 0.95
ListKeysMethod · 0.65

Tested by 2