func()

in pkg/controller/liveness/liveness.go [301:318]

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

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