Class PollingRemoteConfigurationSource
java.lang.Object
io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationSource
- All Implemented Interfaces:
RemoteConfigurationSource
- Direct Known Subclasses:
FileRemoteConfigSource,HttpRemoteConfigurationSource,KubernetesRemoteConfigurationSource
public abstract class PollingRemoteConfigurationSource
extends Object
implements RemoteConfigurationSource
-
Method Summary
Modifier and TypeMethodDescriptionio.confluent.telemetry.config.v2.remote.RemoteConfigurationReturns the latest received configuration from this source.voidsetConfigurationChangeCallback(Consumer<io.confluent.telemetry.config.v2.remote.RemoteConfiguration> callback) Only one callback can be registered.voidstart()voidstop()
-
Method Details
-
getConfig
public io.confluent.telemetry.config.v2.remote.RemoteConfiguration getConfig()Description copied from interface:RemoteConfigurationSourceReturns the latest received configuration from this source.- Specified by:
getConfigin interfaceRemoteConfigurationSource
-
setConfigurationChangeCallback
public void setConfigurationChangeCallback(Consumer<io.confluent.telemetry.config.v2.remote.RemoteConfiguration> callback) Only one callback can be registered. If a callback is already registered it'll be replaced by new provided callback- Specified by:
setConfigurationChangeCallbackin interfaceRemoteConfigurationSource
-
stop
public void stop()- Specified by:
stopin interfaceRemoteConfigurationSource
-
start
public void start()- Specified by:
startin interfaceRemoteConfigurationSource
-