Interface RmWatcher<T extends io.confluent.resourcemanager.api.model.HasMetadata>

public interface RmWatcher<T extends io.confluent.resourcemanager.api.model.HasMetadata>

Shim interface for Watcher. This is added for easier testing and to constrain our usage of the RM Watch client.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	RmWatcher.ContinueFromEnd	Start a watch stream at its tail.
static class	RmWatcher.ContinueWithToken	Continue a watch stream from a token.
static interface	RmWatcher.InitializationStrategy	Strategy for how the watch stream is initialized
static class	RmWatcher.LoadSnapshot	Start a watch stream with a full snapshot.

Method Summary

Modifier and Type	Method	Description
RmWatcher<T>	completionHandler(Runnable completionHandler)
RmWatcher<T>	errorHandler(Consumer<Throwable> errorHandler)
RmWatcher<T>	eventHandler(Consumer<io.confluent.resourcemanager.api.client.WatchEvent<T>> eventHandler)
RmWatcher<T>	initializationStrategy(RmWatcher.InitializationStrategy initializationStrategy)
RmWatcher<T>	labelSelector(String labelSelector)
RmSubscription	subscribe()
RmWatcher<T>	subscriptionId(String subscriptionId)

Method Details

subscriptionId

RmWatcher<T> subscriptionId(String subscriptionId)

labelSelector

RmWatcher<T> labelSelector(String labelSelector)

initializationStrategy

RmWatcher<T> initializationStrategy(RmWatcher.InitializationStrategy initializationStrategy)

eventHandler

RmWatcher<T> eventHandler(Consumer<io.confluent.resourcemanager.api.client.WatchEvent<T>> eventHandler)

errorHandler

RmWatcher<T> errorHandler(Consumer<Throwable> errorHandler)

completionHandler

RmWatcher<T> completionHandler(Runnable completionHandler)

subscribe

RmSubscription subscribe()