Method doRemoveWatch

pkg/watch/manager.go:210–250

(ctx context.Context, r *Registrar, gvk schema.GroupVersionKind)

}

func (wm *Manager) doRemoveWatch(ctx context.Context, r *Registrar, gvk schema.GroupVersionKind) error {
	// lock acquired by caller

	v, ok := wm.watchedKinds[gvk]
	if !ok || !v.registrars[r] {
		// Not watching.
		return nil
	}

	// Cancel any replays that may be pending
	wm.cancelReplay(r, gvk)

	// Remove this registrar from the watch list
	delete(v.registrars, r)

	// Skip if there are additional watchers that would prevent us from removing it
	if len(v.registrars) > 0 {
		return nil
	}

	log.Info("all watches removed for gvk, waiting for replays to end", "gvk", gvk)

	// Wait until all replays have exited before canceling the watch,
	// otherwise the list may unintentionally restart a watch
	select {
	case <-wm.replayTracker.replayWaitCh(gvk):
	case <-wm.stopped:
	}

	u := &unstructured.Unstructured{}
	u.SetGroupVersionKind(gvk)
	if err := wm.cache.RemoveInformer(ctx, u); err != nil {
		return fmt.Errorf("removing %+v: %w", gvk, err)
	}
	delete(wm.watchedKinds, gvk)
	if err := wm.metrics.reportGvkCount(int64(len(wm.watchedKinds))); err != nil {
		log.Error(err, "while trying to report gvk count metric")
	}
	log.Info("watch removed", "gvk", gvk)
	return nil
}

// replaceWatches ensures all and only desired watches are running.
func (wm *Manager) replaceWatches(ctx context.Context, r *Registrar) error {