func()

in pkg/controller/liveness/liveness.go [275:292]

• 18 lines of code
• 3 McCabe index (conditional complexity)

func (hc *HealthCheck) checkIngressQueueHealth() error {
	hc.mutex.RLock()
	defer hc.mutex.RUnlock()
	if !hc.prevSuccessSync.ingressScheduled {
		return nil
	}
	now := time.Now()
	lastIngressResync := hc.lastActivity[IngressResyncProcess]
	if lastIngressResync.Before(hc.prevSuccessSync.runTime) {
		return fmt.Errorf(
			"previous synchronizeAll added Ingress objects to queue %s ago, "+
				"while last processed Ingress %s ago, %s before",
			now.Sub(hc.prevSuccessSync.runTime),
			now.Sub(lastIngressResync),
			hc.prevSuccessSync.runTime.Sub(lastIngressResync))
	}
	return nil
}