io.confluent.remote.config.poller

Class PollingRemoteConfigurationSource<T>

java.lang.Object

io.confluent.remote.config.poller.PollingRemoteConfigurationSource<T>

Type Parameters:

T - The configuration class that would hold the response of the api poll

All Implemented Interfaces:

RemoteConfigurationSource<T>

Direct Known Subclasses:

KubernetesConfigMapRemoteConfigurationSource

public abstract class PollingRemoteConfigurationSource<T>
extends Object
implements RemoteConfigurationSource<T>

This PollingRemoteConfigurationSource class provides a generic polling implementation for remote configuration sources. It uses a single thread executor to poll the remote source.

Constructor Summary

Constructors

Constructor and Description
PollingRemoteConfigurationSource(long refreshIntervalMs, Consumer<T> callback, Class<T> typeParameterClass)

Method Summary

Modifier and Type	Method and Description
T	getConfig() This method is used to get the current configuration before starting the polling.
void	setConfigurationChangeCallback(Consumer<T> 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 Detail

PollingRemoteConfigurationSource

public PollingRemoteConfigurationSource(long refreshIntervalMs,
                                        Consumer<T> callback,
                                        Class<T> typeParameterClass)

Parameters:

refreshIntervalMs - - Executor service delay in milliseconds

callback - - The callback to be called by the scheduled executor thread after polling the remote source

typeParameterClass - - The class type of the configuration object that would hold the response of the api poll

Method Detail

getConfig

public T getConfig()

This method is used to get the current configuration before starting the polling. It's useful to get the initial configuration before starting the polling.

Specified by:

getConfig in interface RemoteConfigurationSource<T>

Returns:

currentConfig

setConfigurationChangeCallback

public void setConfigurationChangeCallback(Consumer<T> 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<T>

stop

public void stop()

Specified by:

stop in interface RemoteConfigurationSource<T>

start

public void start()

Specified by:

start in interface RemoteConfigurationSource<T>