feat: add initial support for camel-k (#1097)

core-starter/camel-k-starter/pom.xml

@@ -0,0 +1,131 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+    Licensed to the Apache Software Foundation (ASF) under one or more
+    contributor license agreements.  See the NOTICE file distributed with
+    this work for additional information regarding copyright ownership.
+    The ASF licenses this file to You 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.
+
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+
+  <parent>
+    <groupId>org.apache.camel.springboot</groupId>
+    <artifactId>core-starter</artifactId>
+    <version>4.5.0-SNAPSHOT</version>
+    <relativePath>../pom.xml</relativePath>
+  </parent>
+
+  <artifactId>camel-k-starter</artifactId>
+  <packaging>jar</packaging>
+  <name>Camel SB Starters :: camel-k</name>
+
+  <dependencies>
+
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-starter</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.camel.springboot</groupId>
+      <artifactId>camel-core-starter</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.camel.springboot</groupId>
+      <artifactId>camel-kubernetes-starter</artifactId>
+    </dependency>
+
+    <!-- Testing dependencies -->
+    <dependency>
+      <groupId>org.apache.camel</groupId>
+      <artifactId>camel-test-spring-junit5</artifactId>
+      <exclusions>
+        <exclusion>
+          <groupId>org.apache.camel</groupId>
+          <artifactId>camel-spring-xml</artifactId>
+        </exclusion>
+      </exclusions>
+      <scope>test</scope>
+    </dependency>
+
+    <dependency>
+      <groupId>org.awaitility</groupId>
+      <artifactId>awaitility</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-starter-test</artifactId>
+      <scope>test</scope>
+    </dependency>
+
+
+    <dependency>
+      <groupId>org.apache.camel.springboot</groupId>
+      <artifactId>camel-yaml-dsl-starter</artifactId>
+      <scope>test</scope>
+    </dependency>
+
+  </dependencies>
+
+
+  <build>
+    <plugins>
+
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-compiler-plugin</artifactId>
+        <version>${maven-compiler-plugin-version}</version>
+        <configuration>
+          <source>${jdk.version}</source>
+          <target>${jdk.version}</target>
+          <maxmem>512M</maxmem>
+          <fork>${compiler.fork}</fork>
+          <!-- needed by spring boot actuator -->
+          <parameters>true</parameters>
+        </configuration>
+      </plugin>
+
+      <plugin>
+        <groupId>org.apache.camel</groupId>
+        <artifactId>camel-package-maven-plugin</artifactId>
+        <version>${camel-version}</version>
+        <executions>
+          <execution>
+            <id>generate</id>
+            <goals>
+              <goal>prepare-components</goal>
+              <goal>generate-components-list</goal>
+            </goals>
+            <phase>process-classes</phase>
+          </execution>
+        </executions>
+      </plugin>
+
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-surefire-plugin</artifactId>
+        <configuration>
+          <environmentVariables>
+            <CAMEL_K_CONF>${project.basedir}/src/test/resources/camel-k/conf.properties</CAMEL_K_CONF>
+            <CAMEL_K_CONF_D>${project.basedir}/src/test/resources/camel-k/conf.d</CAMEL_K_CONF_D>
+          </environmentVariables>
+        </configuration>
+      </plugin>
+
+    </plugins>
+
+  </build>
+
+</project>

core-starter/camel-k-starter/src/main/java/org/apache/camel/spring/boot/k/ApplicationConfiguration.java

@@ -0,0 +1,164 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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 org.apache.camel.spring.boot.k;
+
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.boot.context.properties.NestedConfigurationProperty;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@ConfigurationProperties(prefix = "camel.k")
+public class ApplicationConfiguration {
+    /**
+     * Global option to enable/disable Camel K.
+     */
+    private boolean enabled;
+
+
+    @NestedConfigurationProperty
+    private final ShutdownProperties shutdown = new ShutdownProperties();
+
+    @NestedConfigurationProperty
+    private final RoutesProperties routes = new RoutesProperties();
+
+
+    public boolean isEnabled() {
+        return enabled;
+    }
+
+    public void setEnabled(boolean enabled) {
+        this.enabled = enabled;
+    }
+
+    public ShutdownProperties getShutdown() {
+        return shutdown;
+    }
+
+    public RoutesProperties getRoutes() {
+        return routes;
+    }
+
+    public static class RoutesProperties {
+        /**
+         * To define some rules to im-place replace some aspect of the loaded routes.
+         */
+        @NestedConfigurationProperty
+        private final List<RouteOverride> overrides = new ArrayList<>();
+
+        public List<RouteOverride> getOverrides() {
+            return overrides;
+        }
+    }
+
+    public static class ShutdownProperties {
+
+        /**
+         * To specify how many messages to process by Camel before automatic terminating the Application or the Camel
+         * Context. If there are inflight messages, the shutdown is delayed till all the exchanges have been completed.
+         */
+        private int maxMessages = 0;
+
+        /**
+         * Controls whether the Camel application should terminate the Application or the CamelContext when the
+         * maxMessages threshold has been reached. Default is {@link ShutdownStrategy#APPLICATION}
+         * <p/>
+         * Note that this is meant to be used mainly for test. In real applications Camel K expects the application to
+         * be stopped.
+         */
+        private ShutdownStrategy strategy = ShutdownStrategy.APPLICATION;
+
+        public int getMaxMessages() {
+            return maxMessages;
+        }
+
+        public void setMaxMessages(int maxMessages) {
+            this.maxMessages = maxMessages;
+        }
+
+        public ShutdownStrategy getStrategy() {
+            return strategy;
+        }
+
+        public void setStrategy(ShutdownStrategy strategy) {
+            this.strategy = strategy;
+        }
+    }
+
+    public enum ShutdownStrategy {
+        APPLICATION,
+        CAMEL
+    }
+
+
+    public static class  RouteOverride {
+        /**
+         * Identifies the route to be amended.
+         */
+        private String id;
+
+        /**
+         * Override for the {@link org.apache.camel.model.FromDefinition} of a
+         * {@link org.apache.camel.model.RouteDefinition}.
+         */
+        private RouteInputOverride input;
+
+        public String getId() {
+            return id;
+        }
+
+        public void setId(String id) {
+            this.id = id;
+        }
+
+        public RouteInputOverride getInput() {
+            return input;
+        }
+
+        public void setInput(RouteInputOverride input) {
+            this.input = input;
+        }
+    }
+
+    public static class RouteInputOverride {
+        /**
+         * The optional endpoint that should be replaced.
+         */
+        private String from;
+
+        /**
+         * The value that should replace the endpoint.
+         */
+        private String with;
+
+        public String getFrom() {
+            return from;
+        }
+
+        public void setFrom(String from) {
+            this.from = from;
+        }
+
+        public String getWith() {
+            return with;
+        }
+
+        public void setWith(String with) {
+            this.with = with;
+        }
+    }
+}

core-starter/camel-k-starter/src/main/java/org/apache/camel/spring/boot/k/ApplicationConstants.java

@@ -0,0 +1,40 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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 org.apache.camel.spring.boot.k;
+
+public final class ApplicationConstants {
+    public static final String ENV_CAMEL_K_CONF = "CAMEL_K_CONF";
+    public static final String PROPERTY_CAMEL_K_CONF = "camel.k.conf";
+
+    public static final String ENV_CAMEL_K_CONF_D = "CAMEL_K_CONF_D";
+    public static final String PROPERTY_CAMEL_K_CONF_D = "camel.k.conf.d";
+
+    public static final String ENV_CAMEL_K_MOUNT_PATH_CONFIGMAPS = "CAMEL_K_MOUNT_PATH_CONFIGMAPS";
+    public static final String PROPERTY_CAMEL_K_MOUNT_PATH_CONFIGMAPS = "camel.k.mount-path.configmaps";
+    public static final String PATH_CONFIGMAPS = "_configmaps";
+
+    public static final String ENV_CAMEL_K_MOUNT_PATH_SECRETS = "CAMEL_K_MOUNT_PATH_SECRETS";
+    public static final String PROPERTY_CAMEL_K_MOUNT_PATH_SECRETS = "camel.k.mount-path.secrets";
+    public static final String PATH_SECRETS = "_secrets";
+
+    public static final String ENV_CAMEL_K_MOUNT_PATH_SERVICEBINDINGS = "CAMEL_K_MOUNT_PATH_SERVICEBINDINGS";
+    public static final String PROPERTY_CAMEL_K_MOUNT_PATH_SERVICEBINDINGS = "camel.k.mount-path.servicebindings";
+    public static final String PATH_SERVICEBINDINGS = "_servicebindings";
+
+    private ApplicationConstants() {
+    }
+}