public boolean isHealthy()

in flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/health/HealthProbe.java [53:80]

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

    public boolean isHealthy() {
        if (runtimeInfo != null) {
            LOG.debug("Checking event source health");
            var healthSummary = InformerHealthSummary.fromRuntimeInfo(runtimeInfo);
            if (!healthSummary.isAnyHealthy()) {
                LOG.error("All informers are unhealthy");
                return false;
            } else if (anyInformerBecameUnhealthy(healthSummary.getUnhealthyInformers())) {
                return false;
            } else {
                previousInformerHealthSummary = healthSummary;
            }

            if (!runtimeInfo.isStarted()) {
                LOG.error("Operator is not running");
                return false;
            }
        }

        for (CanaryResourceManager<?> canaryResourceManager : canaryResourceManagers) {
            if (!canaryResourceManager.allCanariesHealthy()) {
                LOG.error("Unhealthy canary resources");
                return false;
            }
        }

        return true;
    }