Package org.apache.flink.kubernetes.operator.observer

Class ClusterHealthEvaluator

java.lang.Object

org.apache.flink.kubernetes.operator.observer.ClusterHealthEvaluator

public class ClusterHealthEvaluator
extends java.lang.Object

Evaluates whether the cluster is healthy.

Constructor Summary

Constructors

Constructor	Description
ClusterHealthEvaluator(java.time.Clock clock)

Method Summary

Modifier and Type	Method	Description
void	evaluate(org.apache.flink.configuration.Configuration configuration, java.util.Map<java.lang.String,java.lang.String> clusterInfo, ClusterHealthInfo observedClusterHealthInfo)
static ClusterHealthInfo	getLastValidClusterHealthInfo(java.util.Map<java.lang.String,java.lang.String> clusterInfo)
static void	removeLastValidClusterHealthInfo(java.util.Map<java.lang.String,java.lang.String> clusterInfo)
static void	setLastValidClusterHealthInfo(java.util.Map<java.lang.String,java.lang.String> clusterInfo, ClusterHealthInfo clusterHealthInfo)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClusterHealthEvaluator

public ClusterHealthEvaluator(java.time.Clock clock)

Method Detail

getLastValidClusterHealthInfo

public static ClusterHealthInfo getLastValidClusterHealthInfo(java.util.Map<java.lang.String,java.lang.String> clusterInfo)

setLastValidClusterHealthInfo

public static void setLastValidClusterHealthInfo(java.util.Map<java.lang.String,java.lang.String> clusterInfo,
                                                 ClusterHealthInfo clusterHealthInfo)

removeLastValidClusterHealthInfo

public static void removeLastValidClusterHealthInfo(java.util.Map<java.lang.String,java.lang.String> clusterInfo)

evaluate

public void evaluate(org.apache.flink.configuration.Configuration configuration,
                     java.util.Map<java.lang.String,java.lang.String> clusterInfo,
                     ClusterHealthInfo observedClusterHealthInfo)