Package io.confluent.security.audit.telemetry.exporter.config.remote.polling

Class PollingRemoteConfigurationSource<T>

java.lang.Object

io.confluent.security.audit.telemetry.exporter.config.remote.polling.PollingRemoteConfigurationSource<T>

Type Parameters:

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

All Implemented Interfaces:

ICallbackResponse, RemoteConfigurationSource<T>

Direct Known Subclasses:

KubernetesConfigMapRemoteConfigurationSource

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

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	Description
PollingRemoteConfigurationSource(long refreshIntervalMs, Consumer<T> callback, Class<T> typeParameterClass)

Method Summary

Modifier and Type	Method	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

Methods inherited from interface io.confluent.security.audit.telemetry.exporter.config.remote.polling.ICallbackResponse

onCallbackFailure, onCallbackSuccess

Constructor Details

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 Details

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>