This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 45f2fa2cf9a influxdb2
45f2fa2cf9a is described below
commit 45f2fa2cf9a2984c48622e34c814250a958961a2
Author: Claus Ibsen <[email protected]>
AuthorDate: Mon Dec 5 09:32:32 2022 +0100
influxdb2
---
bom/camel-bom/pom.xml | 5 +
camel-dependencies/pom.xml | 1 +
.../org/apache/camel/catalog/components.properties | 1 +
.../apache/camel/catalog/components/influxdb2.json | 45 +++
.../org/apache/camel/main/components.properties | 1 +
.../modules/ROOT/examples/json/influxdb2.json | 1 +
docs/components/modules/ROOT/nav.adoc | 1 +
.../modules/ROOT/pages/influxdb2-component.adoc | 1 +
.../component/ComponentsBuilderFactory.java | 13 +
.../dsl/Influxdb2ComponentBuilderFactory.java | 138 +++++++
.../src/generated/resources/metadata.json | 22 ++
.../builder/endpoint/EndpointBuilderFactory.java | 1 +
.../camel/builder/endpoint/EndpointBuilders.java | 1 +
.../builder/endpoint/StaticEndpointBuilders.java | 47 +++
.../dsl/InfluxDb2EndpointBuilderFactory.java | 410 +++++++++++++++++++++
.../camel-component-known-dependencies.properties | 1 +
16 files changed, 689 insertions(+)
diff --git a/bom/camel-bom/pom.xml b/bom/camel-bom/pom.xml
index 25c5a2fb5fb..a31145c9390 100644
--- a/bom/camel-bom/pom.xml
+++ b/bom/camel-bom/pom.xml
@@ -1051,6 +1051,11 @@
<artifactId>camel-influxdb</artifactId>
<version>${project.version}</version>
</dependency>
+ <dependency>
+ <groupId>org.apache.camel</groupId>
+ <artifactId>camel-influxdb2</artifactId>
+ <version>${project.version}</version>
+ </dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-iota</artifactId>
diff --git a/camel-dependencies/pom.xml b/camel-dependencies/pom.xml
index b23bda8ffa5..ded98d6d45e 100644
--- a/camel-dependencies/pom.xml
+++ b/camel-dependencies/pom.xml
@@ -266,6 +266,7 @@
<ignite-version>2.12.0</ignite-version>
<impsort-maven-plugin-version>1.6.0</impsort-maven-plugin-version>
<infinispan-version>14.0.3.Final</infinispan-version>
+
<influx-client-java-driver-version>6.7.0</influx-client-java-driver-version>
<influx-guava-version>20.0</influx-guava-version>
<influx-java-driver-version>2.22</influx-java-driver-version>
<irclib-version>1.10</irclib-version>
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
index 51bf87030ec..13c2ba81815 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
@@ -162,6 +162,7 @@ imaps
infinispan
infinispan-embedded
influxdb
+influxdb2
iota
ipfs
irc
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/influxdb2.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/influxdb2.json
new file mode 100644
index 00000000000..b6340c9eb38
--- /dev/null
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/influxdb2.json
@@ -0,0 +1,45 @@
+{
+ "component": {
+ "kind": "component",
+ "name": "influxdb2",
+ "title": "InfluxDB2",
+ "description": "Interact with InfluxDB, a time series database.",
+ "deprecated": false,
+ "firstVersion": "3.20.0",
+ "label": "database",
+ "javaType": "org.apache.camel.component.influxdb2.InfluxDb2Component",
+ "supportLevel": "Preview",
+ "groupId": "org.apache.camel",
+ "artifactId": "camel-influxdb2",
+ "version": "3.20.0-SNAPSHOT",
+ "scheme": "influxdb2",
+ "extendsScheme": "",
+ "syntax": "influxdb2:connectionBean?org=<org name>&bucket=<bucket name>",
+ "async": false,
+ "api": false,
+ "consumerOnly": false,
+ "producerOnly": true,
+ "lenientProperties": false
+ },
+ "componentProperties": {
+ "influxDBClient": { "kind": "property", "displayName": "Influx DBClient",
"group": "producer", "label": "", "required": false, "type": "object",
"javaType": "com.influxdb.client.InfluxDBClient", "deprecated": false,
"autowired": true, "secret": false, "description": "The shared Influx DB to use
for all endpoints" },
+ "lazyStartProducer": { "kind": "property", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during star [...]
+ "autowiredEnabled": { "kind": "property", "displayName": "Autowired
Enabled", "group": "advanced", "label": "advanced", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which t [...]
+ },
+ "headers": {
+ "CamelInfluxDB2MeasurementName": { "kind": "header", "displayName": "",
"group": "producer", "label": "", "required": false, "javaType": "String",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The name of measurement", "constantName":
"org.apache.camel.component.influxdb2.InfluxDb2Constants#MEASUREMENT" },
+ "camelInfluxDB.RetentionPolicy": { "kind": "header", "displayName": "",
"group": "producer", "label": "", "required": false, "javaType": "String",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The string that defines the retention policy to the data
created by the endpoint", "constantName":
"org.apache.camel.component.influxdb2.InfluxDb2Constants#RETENTION_POLICY" },
+ "CamelInfluxDB2WritePrecision": { "kind": "header", "displayName": "",
"group": "producer", "label": "", "required": false, "javaType":
"com.influxdb.client.domain.WritePrecision", "enum": [ "ms", "s", "us", "ns" ],
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "InfluxDb Write precision.", "constantName":
"org.apache.camel.component.influxdb2.InfluxDb2Constants#WRITE_PRECISION" }
+ },
+ "properties": {
+ "connectionBean": { "kind": "path", "displayName": "Connection Bean",
"group": "producer", "label": "", "required": true, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "Connection to the influx2
database, of class com.influxdb.client.InfluxDBClient.class." },
+ "autoCreateBucket": { "kind": "parameter", "displayName": "Auto Create
Bucket", "group": "producer", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Define if we want to
auto create the bucket if it's not present." },
+ "autoCreateOrg": { "kind": "parameter", "displayName": "Auto Create Org",
"group": "producer", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "description": "Define if we want to auto create
the organization if it's not present." },
+ "bucket": { "kind": "parameter", "displayName": "Bucket", "group":
"producer", "label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The name of the bucket where the time
series will be stored." },
+ "operation": { "kind": "parameter", "displayName": "Operation", "group":
"producer", "label": "", "required": false, "type": "object", "javaType":
"org.apache.camel.component.influxdb2.enums.Operation", "enum": [ "INSERT",
"PING" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "INSERT", "description": "Define if this operation is an insert
of ping." },
+ "org": { "kind": "parameter", "displayName": "Org", "group": "producer",
"label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The name of the organization where the
time series will be stored." },
+ "retentionPolicy": { "kind": "parameter", "displayName": "Retention
Policy", "group": "producer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "default", "description": "Define the
retention policy to the data created by the endpoint." },
+ "writePrecision": { "kind": "parameter", "displayName": "Write Precision",
"group": "producer", "label": "", "required": false, "type": "object",
"javaType": "com.influxdb.client.domain.WritePrecision", "enum": [ "ms", "s",
"us", "ns" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "ms", "description": "The format or precision of time series
timestamps. see
here(https:\/\/docs.influxdata.com\/influxdb\/latest\/reference\/glossary\/#precision)"
},
+ "lazyStartProducer": { "kind": "parameter", "displayName": "Lazy Start
Producer", "group": "producer (advanced)", "label": "producer,advanced",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "autowired": false, "secret": false, "defaultValue": false,
"description": "Whether the producer should be started lazy (on the first
message). By starting lazy you can use this to allow CamelContext and routes to
startup in situations where a producer may other [...]
+ }
+}
diff --git
a/core/camel-main/src/generated/resources/org/apache/camel/main/components.properties
b/core/camel-main/src/generated/resources/org/apache/camel/main/components.properties
index 51bf87030ec..13c2ba81815 100644
---
a/core/camel-main/src/generated/resources/org/apache/camel/main/components.properties
+++
b/core/camel-main/src/generated/resources/org/apache/camel/main/components.properties
@@ -162,6 +162,7 @@ imaps
infinispan
infinispan-embedded
influxdb
+influxdb2
iota
ipfs
irc
diff --git a/docs/components/modules/ROOT/examples/json/influxdb2.json
b/docs/components/modules/ROOT/examples/json/influxdb2.json
new file mode 120000
index 00000000000..00ce577509f
--- /dev/null
+++ b/docs/components/modules/ROOT/examples/json/influxdb2.json
@@ -0,0 +1 @@
+../../../../../../components/camel-influxdb2/src/generated/resources/org/apache/camel/component/influxdb2/influxdb2.json
\ No newline at end of file
diff --git a/docs/components/modules/ROOT/nav.adoc
b/docs/components/modules/ROOT/nav.adoc
index 96ac179e184..158501e9933 100644
--- a/docs/components/modules/ROOT/nav.adoc
+++ b/docs/components/modules/ROOT/nav.adoc
@@ -166,6 +166,7 @@
** xref:infinispan-component.adoc[Infinispan]
** xref:infinispan-embedded-component.adoc[Infinispan Embedded]
** xref:influxdb-component.adoc[InfluxDB]
+** xref:influxdb2-component.adoc[InfluxDB2]
** xref:iota-component.adoc[IOTA]
** xref:ipfs-component.adoc[IPFS]
** xref:irc-component.adoc[IRC]
diff --git a/docs/components/modules/ROOT/pages/influxdb2-component.adoc
b/docs/components/modules/ROOT/pages/influxdb2-component.adoc
new file mode 120000
index 00000000000..6c5dd85f5c9
--- /dev/null
+++ b/docs/components/modules/ROOT/pages/influxdb2-component.adoc
@@ -0,0 +1 @@
+../../../../../components/camel-influxdb2/src/main/docs/influxdb2-component.adoc
\ No newline at end of file
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java
index 0aae7716fbc..2454c0b3fab 100644
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java
+++
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java
@@ -2225,6 +2225,19 @@ public interface ComponentsBuilderFactory {
static
org.apache.camel.builder.component.dsl.InfluxdbComponentBuilderFactory.InfluxdbComponentBuilder
influxdb() {
return
org.apache.camel.builder.component.dsl.InfluxdbComponentBuilderFactory.influxdb();
}
+ /**
+ * InfluxDB2 (camel-influxdb2)
+ * Interact with InfluxDB, a time series database.
+ *
+ * Category: database
+ * Since: 3.20
+ * Maven coordinates: org.apache.camel:camel-influxdb2
+ *
+ * @return the dsl builder
+ */
+ static
org.apache.camel.builder.component.dsl.Influxdb2ComponentBuilderFactory.Influxdb2ComponentBuilder
influxdb2() {
+ return
org.apache.camel.builder.component.dsl.Influxdb2ComponentBuilderFactory.influxdb2();
+ }
/**
* IOTA (camel-iota)
* Manage financial transactions using IOTA distributed ledger.
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Influxdb2ComponentBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Influxdb2ComponentBuilderFactory.java
new file mode 100644
index 00000000000..8c90ed47227
--- /dev/null
+++
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Influxdb2ComponentBuilderFactory.java
@@ -0,0 +1,138 @@
+/*
+ * 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.builder.component.dsl;
+
+import javax.annotation.Generated;
+import org.apache.camel.Component;
+import org.apache.camel.builder.component.AbstractComponentBuilder;
+import org.apache.camel.builder.component.ComponentBuilder;
+import org.apache.camel.component.influxdb2.InfluxDb2Component;
+
+/**
+ * Interact with InfluxDB, a time series database.
+ *
+ * Generated by camel-package-maven-plugin - do not edit this file!
+ */
+@Generated("org.apache.camel.maven.packaging.ComponentDslMojo")
+public interface Influxdb2ComponentBuilderFactory {
+
+ /**
+ * InfluxDB2 (camel-influxdb2)
+ * Interact with InfluxDB, a time series database.
+ *
+ * Category: database
+ * Since: 3.20
+ * Maven coordinates: org.apache.camel:camel-influxdb2
+ *
+ * @return the dsl builder
+ */
+ static Influxdb2ComponentBuilder influxdb2() {
+ return new Influxdb2ComponentBuilderImpl();
+ }
+
+ /**
+ * Builder for the InfluxDB2 component.
+ */
+ interface Influxdb2ComponentBuilder
+ extends
+ ComponentBuilder<InfluxDb2Component> {
+ /**
+ * The shared Influx DB to use for all endpoints.
+ *
+ * The option is a:
+ * <code>com.influxdb.client.InfluxDBClient</code> type.
+ *
+ * Group: producer
+ *
+ * @param influxDBClient the value to set
+ * @return the dsl builder
+ */
+ default Influxdb2ComponentBuilder influxDBClient(
+ com.influxdb.client.InfluxDBClient influxDBClient) {
+ doSetProperty("influxDBClient", influxDBClient);
+ return this;
+ }
+ /**
+ * Whether the producer should be started lazy (on the first message).
+ * By starting lazy you can use this to allow CamelContext and routes
to
+ * startup in situations where a producer may otherwise fail during
+ * starting and cause the route to fail being started. By deferring
this
+ * startup to be lazy then the startup failure can be handled during
+ * routing messages via Camel's routing error handlers. Beware that
when
+ * the first message is processed then creating and starting the
+ * producer may take a little time and prolong the total processing
time
+ * of the processing.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: producer
+ *
+ * @param lazyStartProducer the value to set
+ * @return the dsl builder
+ */
+ default Influxdb2ComponentBuilder lazyStartProducer(
+ boolean lazyStartProducer) {
+ doSetProperty("lazyStartProducer", lazyStartProducer);
+ return this;
+ }
+ /**
+ * Whether autowiring is enabled. This is used for automatic autowiring
+ * options (the option must be marked as autowired) by looking up in
the
+ * registry to find if there is a single instance of matching type,
+ * which then gets configured on the component. This can be used for
+ * automatic configuring JDBC data sources, JMS connection factories,
+ * AWS Clients, etc.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: advanced
+ *
+ * @param autowiredEnabled the value to set
+ * @return the dsl builder
+ */
+ default Influxdb2ComponentBuilder autowiredEnabled(
+ boolean autowiredEnabled) {
+ doSetProperty("autowiredEnabled", autowiredEnabled);
+ return this;
+ }
+ }
+
+ class Influxdb2ComponentBuilderImpl
+ extends
+ AbstractComponentBuilder<InfluxDb2Component>
+ implements
+ Influxdb2ComponentBuilder {
+ @Override
+ protected InfluxDb2Component buildConcreteComponent() {
+ return new InfluxDb2Component();
+ }
+ @Override
+ protected boolean setPropertyOnComponent(
+ Component component,
+ String name,
+ Object value) {
+ switch (name) {
+ case "influxDBClient": ((InfluxDb2Component)
component).setInfluxDBClient((com.influxdb.client.InfluxDBClient) value);
return true;
+ case "lazyStartProducer": ((InfluxDb2Component)
component).setLazyStartProducer((boolean) value); return true;
+ case "autowiredEnabled": ((InfluxDb2Component)
component).setAutowiredEnabled((boolean) value); return true;
+ default: return false;
+ }
+ }
+ }
+}
\ No newline at end of file
diff --git a/dsl/camel-componentdsl/src/generated/resources/metadata.json
b/dsl/camel-componentdsl/src/generated/resources/metadata.json
index 6bdf3ed142f..856692cef62 100644
--- a/dsl/camel-componentdsl/src/generated/resources/metadata.json
+++ b/dsl/camel-componentdsl/src/generated/resources/metadata.json
@@ -3617,6 +3617,28 @@
"producerOnly": false,
"lenientProperties": false
},
+ "Influxdb2ComponentBuilderFactory": {
+ "kind": "component",
+ "name": "influxdb2",
+ "title": "InfluxDB2",
+ "description": "Interact with InfluxDB, a time series database.",
+ "deprecated": false,
+ "firstVersion": "3.20.0",
+ "label": "database",
+ "javaType": "org.apache.camel.component.influxdb2.InfluxDb2Component",
+ "supportLevel": "Preview",
+ "groupId": "org.apache.camel",
+ "artifactId": "camel-influxdb2",
+ "version": "3.20.0-SNAPSHOT",
+ "scheme": "influxdb2",
+ "extendsScheme": "",
+ "syntax": "influxdb2:connectionBean?org=<org name>&bucket=<bucket name>",
+ "async": false,
+ "api": false,
+ "consumerOnly": false,
+ "producerOnly": true,
+ "lenientProperties": false
+ },
"InfluxdbComponentBuilderFactory": {
"kind": "component",
"name": "influxdb",
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
index e69f3f47480..8cb675d87fb 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
@@ -172,6 +172,7 @@ public interface EndpointBuilderFactory
org.apache.camel.builder.endpoint.dsl.ImageRecognitionEndpointBuilderFactory.ImageRecognitionBuilders,
org.apache.camel.builder.endpoint.dsl.InfinispanEmbeddedEndpointBuilderFactory.InfinispanEmbeddedBuilders,
org.apache.camel.builder.endpoint.dsl.InfinispanRemoteEndpointBuilderFactory.InfinispanRemoteBuilders,
+
org.apache.camel.builder.endpoint.dsl.InfluxDb2EndpointBuilderFactory.InfluxDb2Builders,
org.apache.camel.builder.endpoint.dsl.InfluxDbEndpointBuilderFactory.InfluxDbBuilders,
org.apache.camel.builder.endpoint.dsl.IrcEndpointBuilderFactory.IrcBuilders,
org.apache.camel.builder.endpoint.dsl.IronMQEndpointBuilderFactory.IronMQBuilders,
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
index e7c88d9e4ce..ba1748eafa1 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
@@ -169,6 +169,7 @@ public interface EndpointBuilders
org.apache.camel.builder.endpoint.dsl.ImageRecognitionEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.InfinispanEmbeddedEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.InfinispanRemoteEndpointBuilderFactory,
+
org.apache.camel.builder.endpoint.dsl.InfluxDb2EndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.InfluxDbEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.IrcEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.IronMQEndpointBuilderFactory,
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
index 32352f3b1eb..28c3d5b54b4 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
@@ -7509,6 +7509,53 @@ public class StaticEndpointBuilders {
String path) {
return
org.apache.camel.builder.endpoint.dsl.InfluxDbEndpointBuilderFactory.endpointBuilder(componentName,
path);
}
+ /**
+ * InfluxDB2 (camel-influxdb2)
+ * Interact with InfluxDB, a time series database.
+ *
+ * Category: database
+ * Since: 3.20
+ * Maven coordinates: org.apache.camel:camel-influxdb2
+ *
+ * Syntax: <code>influxdb2:connectionBean?org=<org name>&bucket=<bucket
+ * name></code>
+ *
+ * Path parameter: connectionBean (required)
+ * Connection to the influx2 database, of class
+ * com.influxdb.client.InfluxDBClient.class.
+ *
+ * @param path connectionBean?org=<org name>&bucket=<bucket name>
+ * @return the dsl builder
+ */
+ public static
org.apache.camel.builder.endpoint.dsl.InfluxDb2EndpointBuilderFactory.InfluxDb2EndpointBuilder
influxdb2(
+ String path) {
+ return
org.apache.camel.builder.endpoint.dsl.InfluxDb2EndpointBuilderFactory.endpointBuilder("influxdb2",
path);
+ }
+ /**
+ * InfluxDB2 (camel-influxdb2)
+ * Interact with InfluxDB, a time series database.
+ *
+ * Category: database
+ * Since: 3.20
+ * Maven coordinates: org.apache.camel:camel-influxdb2
+ *
+ * Syntax: <code>influxdb2:connectionBean?org=<org name>&bucket=<bucket
+ * name></code>
+ *
+ * Path parameter: connectionBean (required)
+ * Connection to the influx2 database, of class
+ * com.influxdb.client.InfluxDBClient.class.
+ *
+ * @param componentName to use a custom component name for the endpoint
+ * instead of the default name
+ * @param path connectionBean?org=<org name>&bucket=<bucket name>
+ * @return the dsl builder
+ */
+ public static
org.apache.camel.builder.endpoint.dsl.InfluxDb2EndpointBuilderFactory.InfluxDb2EndpointBuilder
influxdb2(
+ String componentName,
+ String path) {
+ return
org.apache.camel.builder.endpoint.dsl.InfluxDb2EndpointBuilderFactory.endpointBuilder(componentName,
path);
+ }
/**
* IOTA (camel-iota)
* Manage financial transactions using IOTA distributed ledger.
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/InfluxDb2EndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/InfluxDb2EndpointBuilderFactory.java
new file mode 100644
index 00000000000..3484f1eb7ac
--- /dev/null
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/InfluxDb2EndpointBuilderFactory.java
@@ -0,0 +1,410 @@
+/*
+ * 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.builder.endpoint.dsl;
+
+import java.util.*;
+import java.util.concurrent.*;
+import java.util.function.*;
+import java.util.stream.*;
+import javax.annotation.Generated;
+import org.apache.camel.builder.EndpointConsumerBuilder;
+import org.apache.camel.builder.EndpointProducerBuilder;
+import org.apache.camel.builder.endpoint.AbstractEndpointBuilder;
+
+/**
+ * Interact with InfluxDB, a time series database.
+ *
+ * Generated by camel build tools - do NOT edit this file!
+ */
+@Generated("org.apache.camel.maven.packaging.EndpointDslMojo")
+public interface InfluxDb2EndpointBuilderFactory {
+
+
+ /**
+ * Builder for endpoint for the InfluxDB2 component.
+ */
+ public interface InfluxDb2EndpointBuilder extends EndpointProducerBuilder {
+ default AdvancedInfluxDb2EndpointBuilder advanced() {
+ return (AdvancedInfluxDb2EndpointBuilder) this;
+ }
+ /**
+ * Define if we want to auto create the bucket if it's not present.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: producer
+ *
+ * @param autoCreateBucket the value to set
+ * @return the dsl builder
+ */
+ default InfluxDb2EndpointBuilder autoCreateBucket(
+ boolean autoCreateBucket) {
+ doSetProperty("autoCreateBucket", autoCreateBucket);
+ return this;
+ }
+ /**
+ * Define if we want to auto create the bucket if it's not present.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: true
+ * Group: producer
+ *
+ * @param autoCreateBucket the value to set
+ * @return the dsl builder
+ */
+ default InfluxDb2EndpointBuilder autoCreateBucket(
+ String autoCreateBucket) {
+ doSetProperty("autoCreateBucket", autoCreateBucket);
+ return this;
+ }
+ /**
+ * Define if we want to auto create the organization if it's not
+ * present.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: producer
+ *
+ * @param autoCreateOrg the value to set
+ * @return the dsl builder
+ */
+ default InfluxDb2EndpointBuilder autoCreateOrg(boolean autoCreateOrg) {
+ doSetProperty("autoCreateOrg", autoCreateOrg);
+ return this;
+ }
+ /**
+ * Define if we want to auto create the organization if it's not
+ * present.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: true
+ * Group: producer
+ *
+ * @param autoCreateOrg the value to set
+ * @return the dsl builder
+ */
+ default InfluxDb2EndpointBuilder autoCreateOrg(String autoCreateOrg) {
+ doSetProperty("autoCreateOrg", autoCreateOrg);
+ return this;
+ }
+ /**
+ * The name of the bucket where the time series will be stored.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Required: true
+ * Group: producer
+ *
+ * @param bucket the value to set
+ * @return the dsl builder
+ */
+ default InfluxDb2EndpointBuilder bucket(String bucket) {
+ doSetProperty("bucket", bucket);
+ return this;
+ }
+ /**
+ * Define if this operation is an insert of ping.
+ *
+ * The option is a:
+ *
<code>org.apache.camel.component.influxdb2.enums.Operation</code>
type.
+ *
+ * Default: INSERT
+ * Group: producer
+ *
+ * @param operation the value to set
+ * @return the dsl builder
+ */
+ default InfluxDb2EndpointBuilder operation(
+ org.apache.camel.component.influxdb2.enums.Operation
operation) {
+ doSetProperty("operation", operation);
+ return this;
+ }
+ /**
+ * Define if this operation is an insert of ping.
+ *
+ * The option will be converted to a
+ *
<code>org.apache.camel.component.influxdb2.enums.Operation</code>
type.
+ *
+ * Default: INSERT
+ * Group: producer
+ *
+ * @param operation the value to set
+ * @return the dsl builder
+ */
+ default InfluxDb2EndpointBuilder operation(String operation) {
+ doSetProperty("operation", operation);
+ return this;
+ }
+ /**
+ * The name of the organization where the time series will be stored.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Required: true
+ * Group: producer
+ *
+ * @param org the value to set
+ * @return the dsl builder
+ */
+ default InfluxDb2EndpointBuilder org(String org) {
+ doSetProperty("org", org);
+ return this;
+ }
+ /**
+ * Define the retention policy to the data created by the endpoint.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: default
+ * Group: producer
+ *
+ * @param retentionPolicy the value to set
+ * @return the dsl builder
+ */
+ default InfluxDb2EndpointBuilder retentionPolicy(String
retentionPolicy) {
+ doSetProperty("retentionPolicy", retentionPolicy);
+ return this;
+ }
+ /**
+ * The format or precision of time series timestamps. see
+ *
here(https://docs.influxdata.com/influxdb/latest/reference/glossary/#precision).
+ *
+ * The option is a:
+ * <code>com.influxdb.client.domain.WritePrecision</code>
+ * type.
+ *
+ * Default: ms
+ * Group: producer
+ *
+ * @param writePrecision the value to set
+ * @return the dsl builder
+ */
+ default InfluxDb2EndpointBuilder writePrecision(
+ com.influxdb.client.domain.WritePrecision writePrecision) {
+ doSetProperty("writePrecision", writePrecision);
+ return this;
+ }
+ /**
+ * The format or precision of time series timestamps. see
+ *
here(https://docs.influxdata.com/influxdb/latest/reference/glossary/#precision).
+ *
+ * The option will be converted to a
+ * <code>com.influxdb.client.domain.WritePrecision</code>
+ * type.
+ *
+ * Default: ms
+ * Group: producer
+ *
+ * @param writePrecision the value to set
+ * @return the dsl builder
+ */
+ default InfluxDb2EndpointBuilder writePrecision(String writePrecision)
{
+ doSetProperty("writePrecision", writePrecision);
+ return this;
+ }
+ }
+
+ /**
+ * Advanced builder for endpoint for the InfluxDB2 component.
+ */
+ public interface AdvancedInfluxDb2EndpointBuilder
+ extends
+ EndpointProducerBuilder {
+ default InfluxDb2EndpointBuilder basic() {
+ return (InfluxDb2EndpointBuilder) this;
+ }
+ /**
+ * Whether the producer should be started lazy (on the first message).
+ * By starting lazy you can use this to allow CamelContext and routes
to
+ * startup in situations where a producer may otherwise fail during
+ * starting and cause the route to fail being started. By deferring
this
+ * startup to be lazy then the startup failure can be handled during
+ * routing messages via Camel's routing error handlers. Beware that
when
+ * the first message is processed then creating and starting the
+ * producer may take a little time and prolong the total processing
time
+ * of the processing.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: producer (advanced)
+ *
+ * @param lazyStartProducer the value to set
+ * @return the dsl builder
+ */
+ default AdvancedInfluxDb2EndpointBuilder lazyStartProducer(
+ boolean lazyStartProducer) {
+ doSetProperty("lazyStartProducer", lazyStartProducer);
+ return this;
+ }
+ /**
+ * Whether the producer should be started lazy (on the first message).
+ * By starting lazy you can use this to allow CamelContext and routes
to
+ * startup in situations where a producer may otherwise fail during
+ * starting and cause the route to fail being started. By deferring
this
+ * startup to be lazy then the startup failure can be handled during
+ * routing messages via Camel's routing error handlers. Beware that
when
+ * the first message is processed then creating and starting the
+ * producer may take a little time and prolong the total processing
time
+ * of the processing.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: producer (advanced)
+ *
+ * @param lazyStartProducer the value to set
+ * @return the dsl builder
+ */
+ default AdvancedInfluxDb2EndpointBuilder lazyStartProducer(
+ String lazyStartProducer) {
+ doSetProperty("lazyStartProducer", lazyStartProducer);
+ return this;
+ }
+ }
+
+ public interface InfluxDb2Builders {
+ /**
+ * InfluxDB2 (camel-influxdb2)
+ * Interact with InfluxDB, a time series database.
+ *
+ * Category: database
+ * Since: 3.20
+ * Maven coordinates: org.apache.camel:camel-influxdb2
+ *
+ * @return the dsl builder for the headers' name.
+ */
+ default InfluxDb2HeaderNameBuilder influxdb2() {
+ return InfluxDb2HeaderNameBuilder.INSTANCE;
+ }
+ /**
+ * InfluxDB2 (camel-influxdb2)
+ * Interact with InfluxDB, a time series database.
+ *
+ * Category: database
+ * Since: 3.20
+ * Maven coordinates: org.apache.camel:camel-influxdb2
+ *
+ * Syntax: <code>influxdb2:connectionBean?org=<org name>&bucket=<bucket
+ * name></code>
+ *
+ * Path parameter: connectionBean (required)
+ * Connection to the influx2 database, of class
+ * com.influxdb.client.InfluxDBClient.class.
+ *
+ * @param path connectionBean?org=<org name>&bucket=<bucket name>
+ * @return the dsl builder
+ */
+ default InfluxDb2EndpointBuilder influxdb2(String path) {
+ return
InfluxDb2EndpointBuilderFactory.endpointBuilder("influxdb2", path);
+ }
+ /**
+ * InfluxDB2 (camel-influxdb2)
+ * Interact with InfluxDB, a time series database.
+ *
+ * Category: database
+ * Since: 3.20
+ * Maven coordinates: org.apache.camel:camel-influxdb2
+ *
+ * Syntax: <code>influxdb2:connectionBean?org=<org name>&bucket=<bucket
+ * name></code>
+ *
+ * Path parameter: connectionBean (required)
+ * Connection to the influx2 database, of class
+ * com.influxdb.client.InfluxDBClient.class.
+ *
+ * @param componentName to use a custom component name for the endpoint
+ * instead of the default name
+ * @param path connectionBean?org=<org name>&bucket=<bucket name>
+ * @return the dsl builder
+ */
+ default InfluxDb2EndpointBuilder influxdb2(
+ String componentName,
+ String path) {
+ return
InfluxDb2EndpointBuilderFactory.endpointBuilder(componentName, path);
+ }
+ }
+
+ /**
+ * The builder of headers' name for the InfluxDB2 component.
+ */
+ public static class InfluxDb2HeaderNameBuilder {
+ /**
+ * The internal instance of the builder used to access to all the
+ * methods representing the name of headers.
+ */
+ private static final InfluxDb2HeaderNameBuilder INSTANCE = new
InfluxDb2HeaderNameBuilder();
+
+ /**
+ * The name of measurement.
+ *
+ * The option is a: {@code String} type.
+ *
+ * Group: producer
+ *
+ * @return the name of the header {@code InfluxDB2MeasurementName}.
+ */
+ public String influxDB2MeasurementName() {
+ return "InfluxDB2MeasurementName";
+ }
+
+ /**
+ * The string that defines the retention policy to the data created by
+ * the endpoint.
+ *
+ * The option is a: {@code String} type.
+ *
+ * Group: producer
+ *
+ * @return the name of the header {@code InfluxDB.RetentionPolicy}.
+ */
+ public String influxdbRetentionpolicy() {
+ return "InfluxDB.RetentionPolicy";
+ }
+
+ /**
+ * InfluxDb Write precision.
+ *
+ * The option is a: {@code com.influxdb.client.domain.WritePrecision}
+ * type.
+ *
+ * Group: producer
+ *
+ * @return the name of the header {@code InfluxDB2WritePrecision}.
+ */
+ public String influxDB2WritePrecision() {
+ return "InfluxDB2WritePrecision";
+ }
+ }
+ static InfluxDb2EndpointBuilder endpointBuilder(
+ String componentName,
+ String path) {
+ class InfluxDb2EndpointBuilderImpl extends AbstractEndpointBuilder
implements InfluxDb2EndpointBuilder, AdvancedInfluxDb2EndpointBuilder {
+ public InfluxDb2EndpointBuilderImpl(String path) {
+ super(componentName, path);
+ }
+ }
+ return new InfluxDb2EndpointBuilderImpl(path);
+ }
+}
\ No newline at end of file
diff --git
a/dsl/camel-kamelet-main/src/generated/resources/camel-component-known-dependencies.properties
b/dsl/camel-kamelet-main/src/generated/resources/camel-component-known-dependencies.properties
index f64dbe24838..33c8a492374 100644
---
a/dsl/camel-kamelet-main/src/generated/resources/camel-component-known-dependencies.properties
+++
b/dsl/camel-kamelet-main/src/generated/resources/camel-component-known-dependencies.properties
@@ -174,6 +174,7 @@
org.apache.camel.component.ignite.set.IgniteSetComponent=camel:ignite
org.apache.camel.component.infinispan.embedded.InfinispanEmbeddedComponent=camel:infinispan-embedded
org.apache.camel.component.infinispan.remote.InfinispanRemoteComponent=camel:infinispan
org.apache.camel.component.influxdb.InfluxDbComponent=camel:influxdb
+org.apache.camel.component.influxdb2.InfluxDb2Component=camel:influxdb2
org.apache.camel.component.iota.IOTAComponent=camel:iota
org.apache.camel.component.ipfs.IPFSComponent=camel:ipfs
org.apache.camel.component.irc.IrcComponent=camel:irc
