Method replayGVKs

pkg/cachemanager/cachemanager.go:482–522

(ctx context.Context, gvksToRelist []schema.GroupVersionKind, stopCh <-chan struct{})

}

func (c *CacheManager) replayGVKs(ctx context.Context, gvksToRelist []schema.GroupVersionKind, stopCh <-chan struct{}) {
	gvksSet := watch.NewSet()
	gvksSet.Add(gvksToRelist...)

	for gvksSet.Size() != 0 {
		gvkItems := gvksSet.Items()

		for _, gvk := range gvkItems {
			select {
			case <-ctx.Done():
				return
			case <-stopCh:
				return
			default:
				operation := func(ctx context.Context) (bool, error) {
					select {
					// make sure that the stop channel hasn't closed yet in order to stop
					// the operation in the backoff retry-er earlier so we don't sync GVKs
					// that we may not want to sync anymore. This also ensures that we exit
					// the func as soon as possible.
					case <-stopCh:
						return true, nil
					default:
						if err := c.syncGVK(ctx, gvk); err != nil {
							return false, err
						}
						return true, nil
					}
				}

				if err := wait.ExponentialBackoffWithContext(ctx, backoff, operation); err != nil {
					log.Error(err, "internal: error listings gvk cache data", "gvk", gvk)
				} else {
					gvksSet.Remove(gvk)
				}
			}
		}

		c.ReportSyncMetrics()
	}
}

// wipeCacheIfNeeded performs a cache wipe if there are any gvks needing to be removed
// from the cache or if the excluder has changed. It also marks which gvks need to be