public abstract class PollingRemoteConfigurationSource extends Object implements RemoteConfigurationSource
Constructor and Description |
---|
PollingRemoteConfigurationSource(long refreshIntervalMs,
Consumer<io.confluent.telemetry.config.remote.v1.RemoteConfiguration> callback) |
Modifier and Type | Method and Description |
---|---|
io.confluent.telemetry.config.remote.v1.RemoteConfiguration |
getConfig()
Returns the latest received configuration from this source.
|
void |
setConfigurationChangeCallback(Consumer<io.confluent.telemetry.config.remote.v1.RemoteConfiguration> callback)
Only one callback can be registered.
|
void |
start() |
void |
stop() |
public PollingRemoteConfigurationSource(long refreshIntervalMs, Consumer<io.confluent.telemetry.config.remote.v1.RemoteConfiguration> callback)
public io.confluent.telemetry.config.remote.v1.RemoteConfiguration getConfig()
RemoteConfigurationSource
getConfig
in interface RemoteConfigurationSource
public void setConfigurationChangeCallback(Consumer<io.confluent.telemetry.config.remote.v1.RemoteConfiguration> callback)
setConfigurationChangeCallback
in interface RemoteConfigurationSource
public void stop()
stop
in interface RemoteConfigurationSource
public void start()
start
in interface RemoteConfigurationSource