Package org.apache.flink.kubernetes.operator.health

Class CanaryResourceManager<CR extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,?>>

java.lang.Object

org.apache.flink.kubernetes.operator.health.CanaryResourceManager<CR>

public class CanaryResourceManager<CR extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,?>>
extends java.lang.Object

Logic encapsulating canary tests.

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	CANARY_LABEL

Constructor Summary

Constructors

Constructor	Description
CanaryResourceManager()

Method Summary

Modifier and Type	Method	Description
boolean	allCanariesHealthy()
protected void	checkHealth(io.javaoperatorsdk.operator.processing.event.ResourceID resourceID, io.fabric8.kubernetes.client.KubernetesClient client)
int	getNumberOfActiveCanaries()
boolean	handleCanaryResourceDeletion(CR resource)
boolean	handleCanaryResourceReconciliation(CR resource, io.fabric8.kubernetes.client.KubernetesClient client)
static boolean	isCanaryResource(io.fabric8.kubernetes.api.model.HasMetadata resource)

Methods inherited from class java.lang.Object

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

Field Detail

CANARY_LABEL

public static final java.lang.String CANARY_LABEL

See Also:

Constant Field Values

Constructor Detail

CanaryResourceManager

public CanaryResourceManager()

Method Detail

allCanariesHealthy

public boolean allCanariesHealthy()

handleCanaryResourceReconciliation

public boolean handleCanaryResourceReconciliation(CR resource,
                                                  io.fabric8.kubernetes.client.KubernetesClient client)

handleCanaryResourceDeletion

public boolean handleCanaryResourceDeletion(CR resource)

checkHealth

@VisibleForTesting
protected void checkHealth(io.javaoperatorsdk.operator.processing.event.ResourceID resourceID,
                           io.fabric8.kubernetes.client.KubernetesClient client)

getNumberOfActiveCanaries

@VisibleForTesting
public int getNumberOfActiveCanaries()

isCanaryResource

public static boolean isCanaryResource(io.fabric8.kubernetes.api.model.HasMetadata resource)