KubernetesSharedWatcher (Flink : Kubernetes 2.1.1-cp2 API)

All Superinterfaces:

AutoCloseable

All Known Subinterfaces:

KubernetesConfigMapSharedWatcher

All Known Implementing Classes:

KubernetesConfigMapSharedInformer, KubernetesSharedInformer
```
public interface KubernetesSharedWatcher<T>
extends AutoCloseable
```
The interface for the Kubernetes shared watcher.

Nested Class Summary

Nested Classes
Modifier and Type Interface Description

static interface KubernetesSharedWatcher.Watch
The Watch returned after creating watching, which can be used to close the watching.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`void`	`close()`	Close the shared watcher without Exception.
`KubernetesSharedWatcher.Watch`	`watch(String name, FlinkKubeClient.WatchCallbackHandler<T> callbackHandler, Executor executor)`	Watch the Kubernetes resource with specified name and do the `FlinkKubeClient.WatchCallbackHandler`.

- Method Detail
  - close
```
void close()
```
    Close the shared watcher without Exception.
    
    Specified by:
    
    close in interface AutoCloseable
  - watch
```
KubernetesSharedWatcher.Watch watch(String name,
                                    FlinkKubeClient.WatchCallbackHandler<T> callbackHandler,
                                    @Nullable
                                    Executor executor)
```
    Watch the Kubernetes resource with specified name and do the FlinkKubeClient.WatchCallbackHandler.
    
    Parameters:
    
    name - name to filter the resource to watch
    
    callbackHandler - 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.