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

Constructor Summary

Constructors

Constructor	Description
PollingRemoteConfigurationSource(long refreshIntervalMs, Consumer<io.confluent.telemetry.config.v2.remote.RemoteConfiguration> callback)

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

Constructor Details

PollingRemoteConfigurationSource

public PollingRemoteConfigurationSource(long refreshIntervalMs,
 Consumer<io.confluent.telemetry.config.v2.remote.RemoteConfiguration> callback)

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