Method WaitForSync

backend/handlers/base/informers.go:85–95

(ctx context.Context)

}

func (h *BaseHandler) WaitForSync(ctx context.Context) {
	ctx, cancel := context.WithTimeout(ctx, 30*time.Second)
	defer cancel()

	if !cache.WaitForCacheSync(ctx.Done(), h.Informer.HasSynced) {
		log.Warn("failed to sync informer within timeout", "kind", h.Kind)
		return
	}

	h.Container.EventProcessor().AddEvent(h.Kind, h.processListEvents(""))
}

func (h *BaseHandler) processListEvents(resourceName string) func() {
	return func() {