...
Code Block | ||
---|---|---|
| ||
public interface ConfigProvider extends Configurable, Closeable { // Configure this class with the initialization parameters void configure(Map<String, ?> configs); // Initialize the provider void init(ConfigContext ctx); // Transform the configs by resolving all indirect references Map<String, String> transform(ConfigContext ctx, Map<String, String> configs); } public interface ConfigContext { // Get the initialization parameters Map<String, String> parameters(); // The name of the connector String connectorName(); // Schedule a reload, possibly for secrets rotation void scheduleConfigReload(long delayMs); } |
...