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

Class KubernetesSharedInformer<T extends io.fabric8.kubernetes.api.model.HasMetadata,R>

java.lang.Object

org.apache.flink.kubernetes.kubeclient.resources.KubernetesSharedInformer<T,R>

All Implemented Interfaces:

AutoCloseable, KubernetesSharedWatcher<R>

Direct Known Subclasses:

KubernetesConfigMapSharedInformer

public abstract class KubernetesSharedInformer<T extends io.fabric8.kubernetes.api.model.HasMetadata,R>
extends Object
implements KubernetesSharedWatcher<R>

Base class for shared watcher based on SharedIndexInformer.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.kubernetes.kubeclient.KubernetesSharedWatcher

KubernetesSharedWatcher.Watch

Field Summary

Fields

Modifier and Type	Field	Description
protected org.slf4j.Logger	log

Constructor Summary

Constructors

Constructor	Description
KubernetesSharedInformer(io.fabric8.kubernetes.client.NamespacedKubernetesClient client, io.fabric8.kubernetes.client.dsl.Informable<T> informable, java.util.function.Function<T,R> eventWrapper)

Method Summary

Modifier and Type	Method	Description
void	close()	Close the shared watcher without Exception.
KubernetesSharedWatcher.Watch	watch(String name, FlinkKubeClient.WatchCallbackHandler<R> handler, Executor executor)	Watch the Kubernetes resource with specified name and do the FlinkKubeClient.WatchCallbackHandler.

Methods inherited from class java.lang.Object

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

Field Detail

log

protected final org.slf4j.Logger log

Constructor Detail

KubernetesSharedInformer

public KubernetesSharedInformer(io.fabric8.kubernetes.client.NamespacedKubernetesClient client,
                                io.fabric8.kubernetes.client.dsl.Informable<T> informable,
                                java.util.function.Function<T,R> eventWrapper)

Method Detail

watch

public KubernetesSharedWatcher.Watch watch(String name,
                                           FlinkKubeClient.WatchCallbackHandler<R> handler,
                                           @Nullable
                                           Executor executor)

Description copied from interface: KubernetesSharedWatcher

Watch the Kubernetes resource with specified name and do the FlinkKubeClient.WatchCallbackHandler.

Specified by:

watch in interface KubernetesSharedWatcher<T extends io.fabric8.kubernetes.api.model.HasMetadata>

Parameters:

name - name to filter the resource to watch

handler - callbackHandler which reacts to resource events

executor - to run callback

Returns:

Return a watch for the Kubernetes resource. It needs to be closed after use.

close

public void close()

Description copied from interface: KubernetesSharedWatcher

Close the shared watcher without Exception.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface KubernetesSharedWatcher<T extends io.fabric8.kubernetes.api.model.HasMetadata>