Package org.apache.druid.common.config

Class ConfigManager

java.lang.Object

org.apache.druid.common.config.ConfigManager

public class ConfigManager
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ConfigManager.SetResult

Constructor Summary

Constructors

Constructor	Description
ConfigManager(MetadataStorageConnector dbConnector, com.google.common.base.Supplier<MetadataStorageTablesConfig> dbTables, com.google.common.base.Supplier<ConfigManagerConfig> config)

Method Summary

Modifier and Type	Method	Description
<T> boolean	addListener(String configKey, String listenerKey, Consumer<T> listener)
<T> boolean	removeListener(String configKey, String listenerKey, Consumer<T> listener)
<T> ConfigManager.SetResult	set(String key, ConfigSerde<T> serde, byte[] oldValue, T newObject)
<T> ConfigManager.SetResult	set(String key, ConfigSerde<T> serde, T obj)
void	start()
void	stop()
<T> AtomicReference<T>	watchConfig(String key, ConfigSerde<T> serde)

Methods inherited from class java.lang.Object

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

Constructor Details

ConfigManager

@Inject
public ConfigManager(MetadataStorageConnector dbConnector,
 com.google.common.base.Supplier<MetadataStorageTablesConfig> dbTables,
 com.google.common.base.Supplier<ConfigManagerConfig> config)

Method Details

start

public void start()

stop

public void stop()

watchConfig

public <T> AtomicReference<T> watchConfig(String key,
 ConfigSerde<T> serde)

set

public <T> ConfigManager.SetResult set(String key,
 ConfigSerde<T> serde,
 T obj)

set

public <T> ConfigManager.SetResult set(String key,
 ConfigSerde<T> serde,
 @Nullable
 byte[] oldValue,
 T newObject)

addListener

public <T> boolean addListener(String configKey,
 String listenerKey,
 Consumer<T> listener)

removeListener

public <T> boolean removeListener(String configKey,
 String listenerKey,
 Consumer<T> listener)