yaml config provider

Signed-off-by: Attila Mészáros <a_meszaros@apple.com>

Author: csviri

operator-framework/src/main/java/io/javaoperatorsdk/operator/config/loader/ConfigLoader.java

@@ -26,8 +26,8 @@
 import io.fabric8.kubernetes.api.model.HasMetadata;
 import io.javaoperatorsdk.operator.api.config.ConfigurationServiceOverrider;
 import io.javaoperatorsdk.operator.api.config.ControllerConfigurationOverrider;
+import io.javaoperatorsdk.operator.config.loader.provider.AgregatePrirityListConfigProvider;
 import io.javaoperatorsdk.operator.config.loader.provider.EnvVarConfigProvider;
-import io.javaoperatorsdk.operator.config.loader.provider.PrirityListConfigProvider;
 import io.javaoperatorsdk.operator.config.loader.provider.SystemPropertyConfigProvider;
 import io.javaoperatorsdk.operator.processing.retry.GenericRetry;
 
@@ -143,7 +143,7 @@ public static ConfigLoader getDefault() {
 
   public ConfigLoader() {
     this(
-        new PrirityListConfigProvider(
+        new AgregatePrirityListConfigProvider(
             List.of(new EnvVarConfigProvider(), new SystemPropertyConfigProvider())),
         DEFAULT_CONTROLLER_KEY_PREFIX,
         DEFAULT_OPERATOR_KEY_PREFIX);

…/provider/PrirityListConfigProvider.java …r/AgregatePrirityListConfigProvider.javaoperator-framework/src/main/java/io/javaoperatorsdk/operator/config/loader/provider/PrirityListConfigProvider.java renamed to operator-framework/src/main/java/io/javaoperatorsdk/operator/config/loader/provider/AgregatePrirityListConfigProvider.java operator-framework/src/main/java/io/javaoperatorsdk/operator/config/loader/provider/PrirityListConfigProvider.java renamed to operator-framework/src/main/java/io/javaoperatorsdk/operator/config/loader/provider/AgregatePrirityListConfigProvider.java

@@ -24,11 +24,11 @@
  * A {@link ConfigProvider} that delegates to an ordered list of providers. Providers are queried in
  * list order; the first non-empty result wins.
  */
-public class PrirityListConfigProvider implements ConfigProvider {
+public class AgregatePrirityListConfigProvider implements ConfigProvider {
 
   private final List<ConfigProvider> providers;
 
-  public PrirityListConfigProvider(List<ConfigProvider> providers) {
+  public AgregatePrirityListConfigProvider(List<ConfigProvider> providers) {
     this.providers = List.copyOf(providers);
   }
 

operator-framework/src/main/java/io/javaoperatorsdk/operator/config/loader/provider/YamlConfigProvider.java

@@ -0,0 +1,89 @@
+/*
+ * Copyright Java Operator SDK Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *         http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.javaoperatorsdk.operator.config.loader.provider;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.UncheckedIOException;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.util.Map;
+import java.util.Optional;
+
+import io.javaoperatorsdk.operator.config.loader.ConfigProvider;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.dataformat.yaml.YAMLFactory;
+
+/**
+ * A {@link ConfigProvider} that resolves configuration values from a YAML file.
+ *
+ * <p>Keys use dot-separated notation to address nested YAML mappings (e.g. {@code
+ * josdk.cache-sync.timeout} maps to {@code josdk → cache-sync → timeout} in the YAML document).
+ * Leaf values are converted to the requested type via {@link ConfigValueConverter}. Supported value
+ * types are: {@link String}, {@link Boolean}, {@link Integer}, {@link Long}, {@link Double}, and
+ * {@link java.time.Duration} (ISO-8601 format, e.g. {@code PT30S}).
+ */
+public class YamlConfigProvider implements ConfigProvider {
+
+  private static final ObjectMapper MAPPER = new ObjectMapper(new YAMLFactory());
+
+  private final Map<String, Object> data;
+
+  /**
+   * Loads YAML from the given file path.
+   *
+   * @throws UncheckedIOException if the file cannot be read
+   */
+  public YamlConfigProvider(Path path) {
+    this.data = load(path);
+  }
+
+  /** Uses the supplied map directly (useful for testing). */
+  public YamlConfigProvider(Map<String, Object> data) {
+    this.data = data;
+  }
+
+  @Override
+  @SuppressWarnings("unchecked")
+  public <T> Optional<T> getValue(String key, Class<T> type) {
+    if (key == null) {
+      return Optional.empty();
+    }
+    String[] parts = key.split("\\.", -1);
+    Object current = data;
+    for (String part : parts) {
+      if (!(current instanceof Map)) {
+        return Optional.empty();
+      }
+      current = ((Map<String, Object>) current).get(part);
+      if (current == null) {
+        return Optional.empty();
+      }
+    }
+    return Optional.of(ConfigValueConverter.convert(current.toString(), type));
+  }
+
+  @SuppressWarnings("unchecked")
+  private static Map<String, Object> load(Path path) {
+    try (InputStream in = Files.newInputStream(path)) {
+      Map<String, Object> result = MAPPER.readValue(in, Map.class);
+      return result != null ? result : Map.of();
+    } catch (IOException e) {
+      throw new UncheckedIOException("Failed to load config YAML from " + path, e);
+    }
+  }
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/config/loader/ConfigLoaderTest.java

@@ -216,8 +216,8 @@ void controllerKeyPrefixIsJosdkControllerDot() {
   // -- binding coverage -------------------------------------------------------
 
   /**
-   * Supported scalar types that PrirityListConfigProvider can parse from a string. Every binding's
-   * type must be one of these.
+   * Supported scalar types that AgregatePrirityListConfigProvider can parse from a string. Every
+   * binding's type must be one of these.
    */
   private static final Set<Class<?>> SUPPORTED_TYPES =
       Set.of(

operator-framework/src/test/java/io/javaoperatorsdk/operator/config/loader/provider/PriorityListConfigProviderTest.java

@@ -26,7 +26,7 @@ class PriorityListConfigProviderTest {
   @Test
   void returnsEmptyWhenAllProvidersReturnEmpty() {
     var provider =
-        new PrirityListConfigProvider(
+        new AgregatePrirityListConfigProvider(
             List.of(
                 new EnvVarConfigProvider(k -> null), new SystemPropertyConfigProvider(k -> null)));
     assertThat(provider.getValue("josdk.no.such.key", String.class)).isEmpty();
@@ -35,7 +35,7 @@ void returnsEmptyWhenAllProvidersReturnEmpty() {
   @Test
   void firstProviderWins() {
     var provider =
-        new PrirityListConfigProvider(
+        new AgregatePrirityListConfigProvider(
             List.of(
                 new EnvVarConfigProvider(k -> k.equals("JOSDK_TEST_KEY") ? "first" : null),
                 new SystemPropertyConfigProvider(
@@ -46,7 +46,7 @@ void firstProviderWins() {
   @Test
   void fallsBackToLaterProviderWhenEarlierReturnsEmpty() {
     var provider =
-        new PrirityListConfigProvider(
+        new AgregatePrirityListConfigProvider(
             List.of(
                 new EnvVarConfigProvider(k -> null),
                 new SystemPropertyConfigProvider(
@@ -61,7 +61,7 @@ void respectsOrderWithThreeProviders() {
         new SystemPropertyConfigProvider(k -> k.equals("josdk.test.key") ? "from-second" : null);
     var third = new EnvVarConfigProvider(k -> k.equals("JOSDK_TEST_KEY") ? "from-third" : null);
 
-    var provider = new PrirityListConfigProvider(List.of(first, second, third));
+    var provider = new AgregatePrirityListConfigProvider(List.of(first, second, third));
     assertThat(provider.getValue("josdk.test.key", String.class)).hasValue("from-second");
   }
 }