Class AbstractWatchManager<T extends HasMetadata>
- java.lang.Object
-
- io.fabric8.kubernetes.client.dsl.internal.AbstractWatchManager<T>
-
- All Implemented Interfaces:
Watch,Closeable,AutoCloseable
- Direct Known Subclasses:
WatchConnectionManager,WatchHTTPManager
public abstract class AbstractWatchManager<T extends HasMetadata> extends Object implements Watch
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classAbstractWatchManager.WatchRequestState
-
Field Summary
Fields Modifier and Type Field Description protected BaseOperation<T,?,?>baseOperationprotected HttpClientclient
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description voidclose()protected abstract voidcloseCurrentRequest()voidcloseRequest()Attempt to gracefully close the current request.booleanisWatching()protected voidonMessage(String message, AbstractWatchManager.WatchRequestState state)protected booleanonStatus(Status status, AbstractWatchManager.WatchRequestState state)voidsetWatchEndCheckMs(int watchEndCheckMs)protected abstract voidstart(URL url, Map<String,String> headers, AbstractWatchManager.WatchRequestState state)protected voidstartWatch()Async start of the watch
-
-
-
Field Detail
-
client
protected final HttpClient client
-
baseOperation
protected BaseOperation<T extends HasMetadata,?,?> baseOperation
-
-
Method Detail
-
start
protected abstract void start(URL url, Map<String,String> headers, AbstractWatchManager.WatchRequestState state)
-
closeRequest
public void closeRequest()
Attempt to gracefully close the current request.If forceClosed has not been set, then it's expected that the watch will attempt to reconnect
-
setWatchEndCheckMs
public void setWatchEndCheckMs(int watchEndCheckMs)
-
closeCurrentRequest
protected abstract void closeCurrentRequest()
-
startWatch
protected void startWatch()
Async start of the watch
-
close
public void close()
-
onMessage
protected void onMessage(String message, AbstractWatchManager.WatchRequestState state)
-
onStatus
protected boolean onStatus(Status status, AbstractWatchManager.WatchRequestState state)
-
isWatching
public boolean isWatching()
-
-