sample with smallrye config

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

@@ -20,6 +20,9 @@
 import java.util.Optional;
 import java.util.function.Consumer;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 import io.fabric8.kubernetes.api.model.HasMetadata;
 import io.javaoperatorsdk.operator.api.config.ConfigurationServiceOverrider;
 import io.javaoperatorsdk.operator.api.config.ControllerConfigurationOverrider;
@@ -30,6 +33,8 @@
 
 public class ConfigLoader {
 
+  private static final Logger log = LoggerFactory.getLogger(ConfigLoader.class);
+
   private static final ConfigLoader DEFAULT = new ConfigLoader();
 
   public static ConfigLoader getDefault() {
@@ -251,7 +256,13 @@ private <O> Consumer<O> buildConsumer(List<ConfigBinding<O, ?>> bindings, String
   private <O, T> Consumer<O> resolveStep(ConfigBinding<O, T> binding, String key) {
     return configProvider
         .getValue(key, binding.type())
-        .map(value -> (Consumer<O>) overrider -> binding.setter().accept(overrider, value))
+        .map(
+            value ->
+                (Consumer<O>)
+                    overrider -> {
+                      log.debug("Found config property: {} = {}", key, value);
+                      binding.setter().accept(overrider, value);
+                    })
         .orElse(null);
   }
 }

sample-operators/tomcat-operator/pom.xml

@@ -39,6 +39,13 @@
         <type>pom</type>
         <scope>import</scope>
       </dependency>
+      <dependency>
+        <groupId>io.smallrye.config</groupId>
+        <artifactId>smallrye-config-bom</artifactId>
+        <version>3.16.0</version>
+        <type>pom</type>
+        <scope>import</scope>
+      </dependency>
     </dependencies>
   </dependencyManagement>
 
@@ -92,6 +99,22 @@
       <artifactId>operator-framework-junit</artifactId>
       <scope>test</scope>
     </dependency>
+
+    <dependency>
+      <groupId>io.smallrye.config</groupId>
+      <artifactId>smallrye-config</artifactId>
+      <version>3.11.4</version>
+    </dependency>
+    <dependency>
+      <groupId>io.smallrye.config</groupId>
+      <artifactId>smallrye-config-source-yaml</artifactId>
+      <version>3.11.4</version>
+    </dependency>
+    <dependency>
+      <groupId>org.eclipse.microprofile.config</groupId>
+      <artifactId>microprofile-config-api</artifactId>
+      <version>3.1</version>
+    </dependency>
   </dependencies>
 
   <build>

sample-operators/tomcat-operator/src/main/java/io/javaoperatorsdk/operator/sample/TomcatOperator.java

@@ -16,6 +16,7 @@
 package io.javaoperatorsdk.operator.sample;
 
 import java.io.IOException;
+import java.net.URL;
 
 import org.takes.facets.fork.FkRegex;
 import org.takes.facets.fork.TkFork;
@@ -24,11 +25,23 @@
 
 import io.javaoperatorsdk.operator.Operator;
 import io.javaoperatorsdk.operator.config.loader.ConfigLoader;
+import io.javaoperatorsdk.operator.sample.smallryeconfig.SmallryeConfigProvider;
+import io.smallrye.config.SmallRyeConfigBuilder;
+import io.smallrye.config.source.yaml.YamlConfigSource;
 
 public class TomcatOperator {
 
   public static void main(String[] args) throws IOException {
-    var configLoader = ConfigLoader.getDefault();
+
+    URL configUrl = TomcatOperator.class.getResource("/application.yaml");
+    if (configUrl == null) {
+      throw new IllegalStateException("application.yaml not found on classpath");
+    }
+    var configLoader =
+        new ConfigLoader(
+            new SmallryeConfigProvider(
+                new SmallRyeConfigBuilder().withSources(new YamlConfigSource(configUrl)).build()));
+
     Operator operator = new Operator(configLoader.applyConfigs());
     operator.register(
         new TomcatReconciler(), configLoader.applyControllerConfigs(TomcatReconciler.NAME));

sample-operators/tomcat-operator/src/main/java/io/javaoperatorsdk/operator/sample/smallryeconfig/SmallryeConfigProvider.java

@@ -0,0 +1,35 @@
+/*
+ * 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.sample.smallryeconfig;
+
+import java.util.Optional;
+
+import io.javaoperatorsdk.operator.config.loader.ConfigProvider;
+import io.smallrye.config.SmallRyeConfig;
+
+public class SmallryeConfigProvider implements ConfigProvider {
+
+  private final SmallRyeConfig smallRyeConfig;
+
+  public SmallryeConfigProvider(SmallRyeConfig smallRyeConfig) {
+    this.smallRyeConfig = smallRyeConfig;
+  }
+
+  @Override
+  public <T> Optional<T> getValue(String key, Class<T> type) {
+    return smallRyeConfig.getOptionalValue(key, type);
+  }
+}

sample-operators/tomcat-operator/src/main/resources/application.yaml

@@ -0,0 +1,62 @@
+#
+# 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.
+#
+
+# JOSDK operator-level configuration (josdk.<property>)
+josdk:
+  check-crd: true
+  close-client-on-stop: true
+  use-ssa-to-patch-primary-resource: false
+  clone-secondary-resources-when-getting-from-cache: false
+  reconciliation:
+    termination-timeout: PT30S
+    concurrent-threads: 10
+  workflow:
+    executor-threads: 10
+  informer:
+    stop-on-error-during-startup: true
+    cache-sync-timeout: PT2M
+  dependent-resources:
+    ssa-based-create-update-match: true
+
+  # Controller-level configuration (josdk.controller.<name>.<property>)
+  controller:
+    tomcat:
+      finalizer: tomcat.sample.javaoperatorsdk.io/finalizer
+      generation-aware: true
+      label-selector: ""
+      max-reconciliation-interval: PT10M
+      field-manager: tomcat-controller
+      trigger-reconciler-on-all-events: false
+      informer-list-limit: 500
+      retry:
+        max-attempts: 10
+        initial-interval: 2000
+        interval-multiplier: 1.5
+        max-interval: 60000
+
+    webapp:
+      finalizer: webapp.sample.javaoperatorsdk.io/finalizer
+      generation-aware: true
+      label-selector: ""
+      max-reconciliation-interval: PT10M
+      field-manager: webapp-controller
+      trigger-reconciler-on-all-events: false
+      informer-list-limit: 500
+      retry:
+        max-attempts: 10
+        initial-interval: 2000
+        interval-multiplier: 1.5
+        max-interval: 60000