Package org.apache.flink.kubernetes.kubeclient.resources

Class AbstractKubernetesWatcher<T extends io.fabric8.kubernetes.api.model.HasMetadata,K extends KubernetesResource<T>>

java.lang.Object

org.apache.flink.kubernetes.kubeclient.resources.AbstractKubernetesWatcher<T,K>

All Implemented Interfaces:

io.fabric8.kubernetes.client.Watcher<T>

Direct Known Subclasses:

KubernetesPodsWatcher

public abstract class AbstractKubernetesWatcher<T extends io.fabric8.kubernetes.api.model.HasMetadata,K extends KubernetesResource<T>>
extends Object
implements io.fabric8.kubernetes.client.Watcher<T>

Watcher for resources in Kubernetes.

Nested Class Summary

Nested classes/interfaces inherited from interface io.fabric8.kubernetes.client.Watcher

io.fabric8.kubernetes.client.Watcher.Action

Field Summary

Fields

Modifier and Type	Field	Description
protected FlinkKubeClient.WatchCallbackHandler<K>	callbackHandler
protected org.slf4j.Logger	logger

Method Summary

Modifier and Type	Method	Description
void	onClose(io.fabric8.kubernetes.client.WatcherException cause)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.fabric8.kubernetes.client.Watcher

eventReceived, onClose, reconnecting

Field Detail

logger

protected final org.slf4j.Logger logger

callbackHandler

protected final FlinkKubeClient.WatchCallbackHandler<K extends KubernetesResource<T>> callbackHandler

Method Detail

onClose

public void onClose(io.fabric8.kubernetes.client.WatcherException cause)

Specified by:

onClose in interface io.fabric8.kubernetes.client.Watcher<T extends io.fabric8.kubernetes.api.model.HasMetadata>