io.confluent.telemetry.config.remote.file

Class FileRemoteConfigSource

java.lang.Object

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

io.confluent.telemetry.config.remote.file.FileRemoteConfigSource

All Implemented Interfaces:

RemoteConfigurationSource

public class FileRemoteConfigSource
extends PollingRemoteConfigurationSource

A RemoteConfigurationSource that supports reading from a local file.

This isn't currently used in production, but is useful for locally testing remote configuration functionality.

Constructor Summary

Constructors

Constructor and Description
FileRemoteConfigSource(FileRemoteConfigConfiguration config, Consumer<io.confluent.telemetry.config.remote.v1.RemoteConfiguration> callback)

Method Summary

Modifier and Type	Method and Description
void	setConfigurationChangeCallback(Consumer<io.confluent.telemetry.config.remote.v1.RemoteConfiguration> callback) Only one callback can be registered.

Methods inherited from class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationSource

getConfig, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

FileRemoteConfigSource

public FileRemoteConfigSource(FileRemoteConfigConfiguration config,
                              Consumer<io.confluent.telemetry.config.remote.v1.RemoteConfiguration> callback)

Method Detail

setConfigurationChangeCallback

public void setConfigurationChangeCallback(Consumer<io.confluent.telemetry.config.remote.v1.RemoteConfiguration> callback)

Description copied from class: PollingRemoteConfigurationSource

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

Overrides:

setConfigurationChangeCallback in class PollingRemoteConfigurationSource