func()

in pkg/controller/controller.go [165:204]

• 31 lines of code
• 7 McCabe index (conditional complexity)

func (c *controller) synchronizeAll(ctx context.Context) {
	// TODO(b/204546048): Add a metric to measure how long syncAll takes.
	// loopStart := time.Now()
	// metrics.UpdateLastTime(metrics.Main, loopStart)
	c.healthCheck.UpdateLastActivity(liveness.SynchronizeAll, time.Now())
	ingressScheduled := false
	mcrtScheduled := false

	if ingresses, err := c.clients.Ingress.List(); err != nil {
		runtime.HandleError(err)
	} else {
		for _, ingress := range ingresses {
			if !ingressutils.IsGKE(ingress) {
				klog.Infof("Skipping non-GKE Ingress %s/%s: %v",
					ingress.Namespace, ingress.Name, *ingress)
			} else {
				queue.Add(c.ingressResyncQueue, ingress)
				ingressScheduled = true
			}
		}
	}

	if managedCertificates, err := c.clients.ManagedCertificate.List(); err != nil {
		runtime.HandleError(err)
	} else {
		for _, managedCertificate := range managedCertificates {
			queue.Add(c.managedCertificateResyncQueue, managedCertificate)
			mcrtScheduled = true
		}
	}

	for id := range c.state.List() {
		queue.AddId(c.managedCertificateResyncQueue, id)
		mcrtScheduled = true
	}

	c.healthCheck.UpdateLastSuccessSync(time.Now(), ingressScheduled, mcrtScheduled)
	// TODO(b/204546048): Add a metric to measure how long syncAll takes.
	// metrics.UpdateDurationFromStart(metrics.Main, loopStart)
}