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

Class KubernetesPodsWatcher

java.lang.Object

org.apache.flink.kubernetes.kubeclient.resources.AbstractKubernetesWatcher<io.fabric8.kubernetes.api.model.Pod,KubernetesPod>

org.apache.flink.kubernetes.kubeclient.resources.KubernetesPodsWatcher

All Implemented Interfaces:

io.fabric8.kubernetes.client.Watcher<io.fabric8.kubernetes.api.model.Pod>

public class KubernetesPodsWatcher
extends AbstractKubernetesWatcher<io.fabric8.kubernetes.api.model.Pod,KubernetesPod>

Watcher for pods 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 inherited from class org.apache.flink.kubernetes.kubeclient.resources.AbstractKubernetesWatcher

callbackHandler, logger

Constructor Summary

Constructors

Constructor	Description
KubernetesPodsWatcher(FlinkKubeClient.WatchCallbackHandler<KubernetesPod> callbackHandler)

Method Summary

Modifier and Type	Method	Description
void	eventReceived(io.fabric8.kubernetes.client.Watcher.Action action, io.fabric8.kubernetes.api.model.Pod pod)

Methods inherited from class org.apache.flink.kubernetes.kubeclient.resources.AbstractKubernetesWatcher

onClose

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

onClose, reconnecting

Constructor Detail

KubernetesPodsWatcher

public KubernetesPodsWatcher(FlinkKubeClient.WatchCallbackHandler<KubernetesPod> callbackHandler)

Method Detail

eventReceived

public void eventReceived(io.fabric8.kubernetes.client.Watcher.Action action,
                          io.fabric8.kubernetes.api.model.Pod pod)