Package io.fabric8.kubernetes.client.dsl.internal

Class WatchHTTPManager<T extends HasMetadata,L extends KubernetesResourceList<T>>

java.lang.Object

io.fabric8.kubernetes.client.dsl.internal.AbstractWatchManager<T>

io.fabric8.kubernetes.client.dsl.internal.WatchHTTPManager<T,L>

All Implemented Interfaces:

Watch, Closeable, AutoCloseable

public class WatchHTTPManager<T extends HasMetadata,L extends KubernetesResourceList<T>>
extends AbstractWatchManager<T>

Nested Class Summary

Nested classes/interfaces inherited from class io.fabric8.kubernetes.client.dsl.internal.AbstractWatchManager

AbstractWatchManager.WatchRequestState

Field Summary

Fields inherited from class io.fabric8.kubernetes.client.dsl.internal.AbstractWatchManager

baseOperation, client

Constructor Summary

Constructors

Constructor	Description
WatchHTTPManager(HttpClient client, BaseOperation<T,L,?> baseOperation, ListOptions listOptions, Watcher<T> watcher, int reconnectInterval, int reconnectLimit)

Method Summary

Modifier and Type	Method	Description
protected void	closeCurrentRequest()
protected void	start(URL url, Map<String,String> headers, AbstractWatchManager.WatchRequestState state)

Methods inherited from class io.fabric8.kubernetes.client.dsl.internal.AbstractWatchManager

close, closeRequest, isWatching, onMessage, onStatus, setWatchEndCheckMs, startWatch

Methods inherited from class java.lang.Object

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

Constructor Detail

WatchHTTPManager

public WatchHTTPManager(HttpClient client,
                        BaseOperation<T,L,?> baseOperation,
                        ListOptions listOptions,
                        Watcher<T> watcher,
                        int reconnectInterval,
                        int reconnectLimit)
                 throws MalformedURLException

Throws:

MalformedURLException

Method Detail

start

protected void start(URL url,
                     Map<String,String> headers,
                     AbstractWatchManager.WatchRequestState state)

Specified by:

start in class AbstractWatchManager<T extends HasMetadata>

closeCurrentRequest

protected void closeCurrentRequest()

Specified by:

closeCurrentRequest in class AbstractWatchManager<T extends HasMetadata>