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 Type	Method	Description
io.confluent.telemetry.config.v2.remote.RemoteConfiguration	getConfig()	Returns the latest received configuration from this source.
void	setConfigurationChangeCallback(Consumer<io.confluent.telemetry.config.v2.remote.RemoteConfiguration> callback)	Only one callback can be registered.
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Method Details

getConfig

public io.confluent.telemetry.config.v2.remote.RemoteConfiguration getConfig()

Description copied from interface: RemoteConfigurationSource

Returns the latest received configuration from this source.

Specified by:

getConfig in interface RemoteConfigurationSource

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:

setConfigurationChangeCallback in interface RemoteConfigurationSource

stop

public void stop()

Specified by:

stop in interface RemoteConfigurationSource

start

public void start()

Specified by:

start in interface RemoteConfigurationSource