io.confluent.telemetry.config.remote.polling

Class PollingRemoteConfigurationSource

java.lang.Object

io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationSource

All Implemented Interfaces:

RemoteConfigurationSource

Direct Known Subclasses:

HttpRemoteConfigurationSource

public abstract class PollingRemoteConfigurationSource
extends Object
implements RemoteConfigurationSource

Constructor Summary

Constructors

Constructor and Description
PollingRemoteConfigurationSource(long refreshIntervalMs)

Method Summary

Modifier and Type	Method and Description
io.confluent.telemetry.config.remote.v1.RemoteConfiguration	getConfig() Returns the latest received configuration from this source.
protected abstract Optional<io.confluent.telemetry.config.remote.RemoteConfigurationResponse>	requestConfig()
void	setConfigurationChangeCallback(Consumer<io.confluent.telemetry.config.remote.v1.RemoteConfiguration> callback) Only one callback can be registered.
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

PollingRemoteConfigurationSource

public PollingRemoteConfigurationSource(long refreshIntervalMs)

Method Detail

getConfig

public io.confluent.telemetry.config.remote.v1.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.remote.v1.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

requestConfig

protected abstract Optional<io.confluent.telemetry.config.remote.RemoteConfigurationResponse> requestConfig()