class KubernetesPodsWatcher implements Watcher<Pod> {

	@Override
	public void onClose(KubernetesClientException cause) {
		// null means the watcher is closed by expected.
		if (cause == null) {
			LOG.info("The pods watcher is closing.");
		} else {
			podsCallbackHandler.handleFatalError(cause);
		}
	}

	public  KubernetesPodsWatcher(FlinkKubeClient.PodCallbackHandler callbackHandler);

}