You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2022/10/04 11:59:49 UTC
[camel] 01/01: Regen
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 6ae7c461907d767404055921fa7b3de9c9d132ee
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Tue Oct 4 06:58:04 2022 -0500
Regen
---
.../org/apache/camel/catalog/components.properties | 1 +
.../apache/camel/catalog/components}/etcd3.json | 2 +-
.../org/apache/camel/component/etcd3/etcd3.json | 2 +-
.../org/apache/camel/main/components.properties | 1 +
.../modules/ROOT/examples/json/etcd3.json | 1 +
.../component/ComponentsBuilderFactory.java | 13 +
.../dsl/Etcd3ComponentBuilderFactory.java | 505 +++++
.../src/generated/resources/metadata.json | 22 +
.../builder/endpoint/EndpointBuilderFactory.java | 1 +
.../camel/builder/endpoint/EndpointBuilders.java | 1 +
.../builder/endpoint/StaticEndpointBuilders.java | 43 +
.../endpoint/dsl/Etcd3EndpointBuilderFactory.java | 1950 ++++++++++++++++++++
.../camel-component-known-dependencies.properties | 1 +
13 files changed, 2541 insertions(+), 2 deletions(-)
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 8d764d76c44..30bff0dd976 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
@@ -91,6 +91,7 @@ dynamic-router
ehcache
elasticsearch
elasticsearch-rest
+etcd3
exec
facebook
fhir
diff --git a/components/camel-etcd3/src/generated/resources/org/apache/camel/component/etcd3/etcd3.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/etcd3.json
similarity index 99%
copy from components/camel-etcd3/src/generated/resources/org/apache/camel/component/etcd3/etcd3.json
copy to catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/etcd3.json
index a2a1bdf5f48..5e86b171346 100644
--- a/components/camel-etcd3/src/generated/resources/org/apache/camel/component/etcd3/etcd3.json
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/etcd3.json
@@ -11,7 +11,7 @@
"supportLevel": "Preview",
"groupId": "org.apache.camel",
"artifactId": "camel-etcd3",
- "version": "3.19.0-SNAPSHOT",
+ "version": "3.20.0-SNAPSHOT",
"scheme": "etcd3",
"extendsScheme": "",
"syntax": "etcd3:path",
diff --git a/components/camel-etcd3/src/generated/resources/org/apache/camel/component/etcd3/etcd3.json b/components/camel-etcd3/src/generated/resources/org/apache/camel/component/etcd3/etcd3.json
index a2a1bdf5f48..5e86b171346 100644
--- a/components/camel-etcd3/src/generated/resources/org/apache/camel/component/etcd3/etcd3.json
+++ b/components/camel-etcd3/src/generated/resources/org/apache/camel/component/etcd3/etcd3.json
@@ -11,7 +11,7 @@
"supportLevel": "Preview",
"groupId": "org.apache.camel",
"artifactId": "camel-etcd3",
- "version": "3.19.0-SNAPSHOT",
+ "version": "3.20.0-SNAPSHOT",
"scheme": "etcd3",
"extendsScheme": "",
"syntax": "etcd3:path",
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 8d764d76c44..30bff0dd976 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
@@ -91,6 +91,7 @@ dynamic-router
ehcache
elasticsearch
elasticsearch-rest
+etcd3
exec
facebook
fhir
diff --git a/docs/components/modules/ROOT/examples/json/etcd3.json b/docs/components/modules/ROOT/examples/json/etcd3.json
new file mode 120000
index 00000000000..1eb85e9905d
--- /dev/null
+++ b/docs/components/modules/ROOT/examples/json/etcd3.json
@@ -0,0 +1 @@
+../../../../../../components/camel-etcd3/src/generated/resources/org/apache/camel/component/etcd3/etcd3.json
\ 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 acdc59d4ef2..742cc1475a5 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
@@ -1282,6 +1282,19 @@ public interface ComponentsBuilderFactory {
static org.apache.camel.builder.component.dsl.ElasticsearchRestComponentBuilderFactory.ElasticsearchRestComponentBuilder elasticsearchRest() {
return org.apache.camel.builder.component.dsl.ElasticsearchRestComponentBuilderFactory.elasticsearchRest();
}
+ /**
+ * Etcd v3 (camel-etcd3)
+ * Get, set, delete or watch keys in etcd key-value store.
+ *
+ * Category: clustering,database
+ * Since: 3.19
+ * Maven coordinates: org.apache.camel:camel-etcd3
+ *
+ * @return the dsl builder
+ */
+ static org.apache.camel.builder.component.dsl.Etcd3ComponentBuilderFactory.Etcd3ComponentBuilder etcd3() {
+ return org.apache.camel.builder.component.dsl.Etcd3ComponentBuilderFactory.etcd3();
+ }
/**
* Exec (camel-exec)
* Execute commands on the underlying operating system.
diff --git a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Etcd3ComponentBuilderFactory.java b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Etcd3ComponentBuilderFactory.java
new file mode 100644
index 00000000000..b1311acaee7
--- /dev/null
+++ b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Etcd3ComponentBuilderFactory.java
@@ -0,0 +1,505 @@
+/*
+ * 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.etcd3.Etcd3Component;
+
+/**
+ * Get, set, delete or watch keys in etcd key-value store.
+ *
+ * Generated by camel-package-maven-plugin - do not edit this file!
+ */
+@Generated("org.apache.camel.maven.packaging.ComponentDslMojo")
+public interface Etcd3ComponentBuilderFactory {
+
+ /**
+ * Etcd v3 (camel-etcd3)
+ * Get, set, delete or watch keys in etcd key-value store.
+ *
+ * Category: clustering,database
+ * Since: 3.19
+ * Maven coordinates: org.apache.camel:camel-etcd3
+ *
+ * @return the dsl builder
+ */
+ static Etcd3ComponentBuilder etcd3() {
+ return new Etcd3ComponentBuilderImpl();
+ }
+
+ /**
+ * Builder for the Etcd v3 component.
+ */
+ interface Etcd3ComponentBuilder extends ComponentBuilder<Etcd3Component> {
+ /**
+ * Component configuration.
+ *
+ * The option is a:
+ * <code>org.apache.camel.component.etcd3.Etcd3Configuration</code> type.
+ *
+ * Group: common
+ *
+ * @param configuration the value to set
+ * @return the dsl builder
+ */
+ default Etcd3ComponentBuilder configuration(
+ org.apache.camel.component.etcd3.Etcd3Configuration configuration) {
+ doSetProperty("configuration", configuration);
+ return this;
+ }
+ /**
+ * Configure etcd server endpoints using the IPNameResolver.
+ *
+ * The option is a: <code>java.lang.String[]</code> type.
+ *
+ * Default: Etcd3Constants.ETCD_DEFAULT_ENDPOINTS
+ * Group: common
+ *
+ * @param endpoints the value to set
+ * @return the dsl builder
+ */
+ default Etcd3ComponentBuilder endpoints(java.lang.String[] endpoints) {
+ doSetProperty("endpoints", endpoints);
+ return this;
+ }
+ /**
+ * Configure the charset to use for the keys.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: UTF-8
+ * Group: common
+ *
+ * @param keyCharset the value to set
+ * @return the dsl builder
+ */
+ default Etcd3ComponentBuilder keyCharset(java.lang.String keyCharset) {
+ doSetProperty("keyCharset", keyCharset);
+ return this;
+ }
+ /**
+ * Configure the namespace of keys used. / will be treated as no
+ * namespace.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param namespace the value to set
+ * @return the dsl builder
+ */
+ default Etcd3ComponentBuilder namespace(java.lang.String namespace) {
+ doSetProperty("namespace", namespace);
+ return this;
+ }
+ /**
+ * To apply an action on all the key-value pairs whose key that starts
+ * with the target path.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: common
+ *
+ * @param prefix the value to set
+ * @return the dsl builder
+ */
+ default Etcd3ComponentBuilder prefix(boolean prefix) {
+ doSetProperty("prefix", prefix);
+ return this;
+ }
+ /**
+ * Allows for bridging the consumer to the Camel routing Error Handler,
+ * which mean any exceptions occurred while the consumer is trying to
+ * pickup incoming messages, or the likes, will now be processed as a
+ * message and handled by the routing Error Handler. By default the
+ * consumer will use the org.apache.camel.spi.ExceptionHandler to deal
+ * with exceptions, that will be logged at WARN or ERROR level and
+ * ignored.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: consumer
+ *
+ * @param bridgeErrorHandler the value to set
+ * @return the dsl builder
+ */
+ default Etcd3ComponentBuilder bridgeErrorHandler(
+ boolean bridgeErrorHandler) {
+ doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
+ return this;
+ }
+ /**
+ * The index to watch from.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 0
+ * Group: consumer (advanced)
+ *
+ * @param fromIndex the value to set
+ * @return the dsl builder
+ */
+ default Etcd3ComponentBuilder fromIndex(long fromIndex) {
+ doSetProperty("fromIndex", fromIndex);
+ 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 Etcd3ComponentBuilder lazyStartProducer(
+ boolean lazyStartProducer) {
+ doSetProperty("lazyStartProducer", lazyStartProducer);
+ return this;
+ }
+ /**
+ * Configure the charset to use for the values.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: UTF-8
+ * Group: producer
+ *
+ * @param valueCharset the value to set
+ * @return the dsl builder
+ */
+ default Etcd3ComponentBuilder valueCharset(java.lang.String valueCharset) {
+ doSetProperty("valueCharset", valueCharset);
+ return this;
+ }
+ /**
+ * Configure the headers to be added to auth request headers.
+ *
+ * The option is a: <code>java.util.Map&lt;java.lang.String,
+ * java.lang.String&gt;</code> type.
+ *
+ * Group: advanced
+ *
+ * @param authHeaders the value to set
+ * @return the dsl builder
+ */
+ default Etcd3ComponentBuilder authHeaders(
+ java.util.Map<java.lang.String, java.lang.String> authHeaders) {
+ doSetProperty("authHeaders", authHeaders);
+ return this;
+ }
+ /**
+ * Configure the authority used to authenticate connections to servers.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: advanced
+ *
+ * @param authority the value to set
+ * @return the dsl builder
+ */
+ default Etcd3ComponentBuilder authority(java.lang.String authority) {
+ doSetProperty("authority", authority);
+ 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 Etcd3ComponentBuilder autowiredEnabled(boolean autowiredEnabled) {
+ doSetProperty("autowiredEnabled", autowiredEnabled);
+ return this;
+ }
+ /**
+ * Configure the connection timeout.
+ *
+ * The option is a: <code>java.time.Duration</code> type.
+ *
+ * Group: advanced
+ *
+ * @param connectionTimeout the value to set
+ * @return the dsl builder
+ */
+ default Etcd3ComponentBuilder connectionTimeout(
+ java.time.Duration connectionTimeout) {
+ doSetProperty("connectionTimeout", connectionTimeout);
+ return this;
+ }
+ /**
+ * Configure the headers to be added to http request headers.
+ *
+ * The option is a: <code>java.util.Map&lt;java.lang.String,
+ * java.lang.String&gt;</code> type.
+ *
+ * Group: advanced
+ *
+ * @param headers the value to set
+ * @return the dsl builder
+ */
+ default Etcd3ComponentBuilder headers(
+ java.util.Map<java.lang.String, java.lang.String> headers) {
+ doSetProperty("headers", headers);
+ return this;
+ }
+ /**
+ * Configure the interval for gRPC keepalives. The current minimum
+ * allowed by gRPC is 10 seconds.
+ *
+ * The option is a: <code>java.time.Duration</code> type.
+ *
+ * Default: 30 seconds
+ * Group: advanced
+ *
+ * @param keepAliveTime the value to set
+ * @return the dsl builder
+ */
+ default Etcd3ComponentBuilder keepAliveTime(
+ java.time.Duration keepAliveTime) {
+ doSetProperty("keepAliveTime", keepAliveTime);
+ return this;
+ }
+ /**
+ * Configure the timeout for gRPC keepalives.
+ *
+ * The option is a: <code>java.time.Duration</code> type.
+ *
+ * Default: 10 seconds
+ * Group: advanced
+ *
+ * @param keepAliveTimeout the value to set
+ * @return the dsl builder
+ */
+ default Etcd3ComponentBuilder keepAliveTimeout(
+ java.time.Duration keepAliveTimeout) {
+ doSetProperty("keepAliveTimeout", keepAliveTimeout);
+ return this;
+ }
+ /**
+ * Configure etcd load balancer policy.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: advanced
+ *
+ * @param loadBalancerPolicy the value to set
+ * @return the dsl builder
+ */
+ default Etcd3ComponentBuilder loadBalancerPolicy(
+ java.lang.String loadBalancerPolicy) {
+ doSetProperty("loadBalancerPolicy", loadBalancerPolicy);
+ return this;
+ }
+ /**
+ * Configure the maximum message size allowed for a single gRPC frame.
+ *
+ * The option is a: <code>java.lang.Integer</code> type.
+ *
+ * Group: advanced
+ *
+ * @param maxInboundMessageSize the value to set
+ * @return the dsl builder
+ */
+ default Etcd3ComponentBuilder maxInboundMessageSize(
+ java.lang.Integer maxInboundMessageSize) {
+ doSetProperty("maxInboundMessageSize", maxInboundMessageSize);
+ return this;
+ }
+ /**
+ * Configure the delay between retries in milliseconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 500
+ * Group: advanced
+ *
+ * @param retryDelay the value to set
+ * @return the dsl builder
+ */
+ default Etcd3ComponentBuilder retryDelay(long retryDelay) {
+ doSetProperty("retryDelay", retryDelay);
+ return this;
+ }
+ /**
+ * Configure the max backing off delay between retries in milliseconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 2500
+ * Group: advanced
+ *
+ * @param retryMaxDelay the value to set
+ * @return the dsl builder
+ */
+ default Etcd3ComponentBuilder retryMaxDelay(long retryMaxDelay) {
+ doSetProperty("retryMaxDelay", retryMaxDelay);
+ return this;
+ }
+ /**
+ * Configure the retries max duration.
+ *
+ * The option is a: <code>java.time.Duration</code> type.
+ *
+ * Group: advanced
+ *
+ * @param retryMaxDuration the value to set
+ * @return the dsl builder
+ */
+ default Etcd3ComponentBuilder retryMaxDuration(
+ java.time.Duration retryMaxDuration) {
+ doSetProperty("retryMaxDuration", retryMaxDuration);
+ return this;
+ }
+ /**
+ * The path to look for service discovery.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: /services/
+ * Group: cloud
+ *
+ * @param servicePath the value to set
+ * @return the dsl builder
+ */
+ default Etcd3ComponentBuilder servicePath(java.lang.String servicePath) {
+ doSetProperty("servicePath", servicePath);
+ return this;
+ }
+ /**
+ * Configure etcd auth password.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param password the value to set
+ * @return the dsl builder
+ */
+ default Etcd3ComponentBuilder password(java.lang.String password) {
+ doSetProperty("password", password);
+ return this;
+ }
+ /**
+ * Configure SSL/TLS context to use instead of the system default.
+ *
+ * The option is a:
+ * <code>io.netty.handler.ssl.SslContext</code> type.
+ *
+ * Group: security
+ *
+ * @param sslContext the value to set
+ * @return the dsl builder
+ */
+ default Etcd3ComponentBuilder sslContext(
+ io.netty.handler.ssl.SslContext sslContext) {
+ doSetProperty("sslContext", sslContext);
+ return this;
+ }
+ /**
+ * Configure etcd auth user.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param userName the value to set
+ * @return the dsl builder
+ */
+ default Etcd3ComponentBuilder userName(java.lang.String userName) {
+ doSetProperty("userName", userName);
+ return this;
+ }
+ }
+
+ class Etcd3ComponentBuilderImpl
+ extends
+ AbstractComponentBuilder<Etcd3Component>
+ implements
+ Etcd3ComponentBuilder {
+ @Override
+ protected Etcd3Component buildConcreteComponent() {
+ return new Etcd3Component();
+ }
+ private org.apache.camel.component.etcd3.Etcd3Configuration getOrCreateConfiguration(
+ org.apache.camel.component.etcd3.Etcd3Component component) {
+ if (component.getConfiguration() == null) {
+ component.setConfiguration(new org.apache.camel.component.etcd3.Etcd3Configuration());
+ }
+ return component.getConfiguration();
+ }
+ @Override
+ protected boolean setPropertyOnComponent(
+ Component component,
+ String name,
+ Object value) {
+ switch (name) {
+ case "configuration": ((Etcd3Component) component).setConfiguration((org.apache.camel.component.etcd3.Etcd3Configuration) value); return true;
+ case "endpoints": getOrCreateConfiguration((Etcd3Component) component).setEndpoints((java.lang.String[]) value); return true;
+ case "keyCharset": getOrCreateConfiguration((Etcd3Component) component).setKeyCharset((java.lang.String) value); return true;
+ case "namespace": getOrCreateConfiguration((Etcd3Component) component).setNamespace((java.lang.String) value); return true;
+ case "prefix": getOrCreateConfiguration((Etcd3Component) component).setPrefix((boolean) value); return true;
+ case "bridgeErrorHandler": ((Etcd3Component) component).setBridgeErrorHandler((boolean) value); return true;
+ case "fromIndex": getOrCreateConfiguration((Etcd3Component) component).setFromIndex((long) value); return true;
+ case "lazyStartProducer": ((Etcd3Component) component).setLazyStartProducer((boolean) value); return true;
+ case "valueCharset": getOrCreateConfiguration((Etcd3Component) component).setValueCharset((java.lang.String) value); return true;
+ case "authHeaders": getOrCreateConfiguration((Etcd3Component) component).setAuthHeaders((java.util.Map) value); return true;
+ case "authority": getOrCreateConfiguration((Etcd3Component) component).setAuthority((java.lang.String) value); return true;
+ case "autowiredEnabled": ((Etcd3Component) component).setAutowiredEnabled((boolean) value); return true;
+ case "connectionTimeout": getOrCreateConfiguration((Etcd3Component) component).setConnectionTimeout((java.time.Duration) value); return true;
+ case "headers": getOrCreateConfiguration((Etcd3Component) component).setHeaders((java.util.Map) value); return true;
+ case "keepAliveTime": getOrCreateConfiguration((Etcd3Component) component).setKeepAliveTime((java.time.Duration) value); return true;
+ case "keepAliveTimeout": getOrCreateConfiguration((Etcd3Component) component).setKeepAliveTimeout((java.time.Duration) value); return true;
+ case "loadBalancerPolicy": getOrCreateConfiguration((Etcd3Component) component).setLoadBalancerPolicy((java.lang.String) value); return true;
+ case "maxInboundMessageSize": getOrCreateConfiguration((Etcd3Component) component).setMaxInboundMessageSize((java.lang.Integer) value); return true;
+ case "retryDelay": getOrCreateConfiguration((Etcd3Component) component).setRetryDelay((long) value); return true;
+ case "retryMaxDelay": getOrCreateConfiguration((Etcd3Component) component).setRetryMaxDelay((long) value); return true;
+ case "retryMaxDuration": getOrCreateConfiguration((Etcd3Component) component).setRetryMaxDuration((java.time.Duration) value); return true;
+ case "servicePath": getOrCreateConfiguration((Etcd3Component) component).setServicePath((java.lang.String) value); return true;
+ case "password": getOrCreateConfiguration((Etcd3Component) component).setPassword((java.lang.String) value); return true;
+ case "sslContext": getOrCreateConfiguration((Etcd3Component) component).setSslContext((io.netty.handler.ssl.SslContext) value); return true;
+ case "userName": getOrCreateConfiguration((Etcd3Component) component).setUserName((java.lang.String) 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 0f4071adb25..56828037543 100644
--- a/dsl/camel-componentdsl/src/generated/resources/metadata.json
+++ b/dsl/camel-componentdsl/src/generated/resources/metadata.json
@@ -2060,6 +2060,28 @@
"producerOnly": true,
"lenientProperties": false
},
+ "Etcd3ComponentBuilderFactory": {
+ "kind": "component",
+ "name": "etcd3",
+ "title": "Etcd v3",
+ "description": "Get, set, delete or watch keys in etcd key-value store.",
+ "deprecated": false,
+ "firstVersion": "3.19.0",
+ "label": "clustering,database",
+ "javaType": "org.apache.camel.component.etcd3.Etcd3Component",
+ "supportLevel": "Preview",
+ "groupId": "org.apache.camel",
+ "artifactId": "camel-etcd3",
+ "version": "3.20.0-SNAPSHOT",
+ "scheme": "etcd3",
+ "extendsScheme": "",
+ "syntax": "etcd3:path",
+ "async": false,
+ "api": false,
+ "consumerOnly": false,
+ "producerOnly": false,
+ "lenientProperties": false
+ },
"ExecComponentBuilderFactory": {
"kind": "component",
"name": "exec",
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 5c2b424edd9..3e69aa65d76 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
@@ -101,6 +101,7 @@ public interface EndpointBuilderFactory
org.apache.camel.builder.endpoint.dsl.EKS2EndpointBuilderFactory.EKS2Builders,
org.apache.camel.builder.endpoint.dsl.EhcacheEndpointBuilderFactory.EhcacheBuilders,
org.apache.camel.builder.endpoint.dsl.ElasticsearchEndpointBuilderFactory.ElasticsearchBuilders,
+ org.apache.camel.builder.endpoint.dsl.Etcd3EndpointBuilderFactory.Etcd3Builders,
org.apache.camel.builder.endpoint.dsl.EventEndpointBuilderFactory.EventBuilders,
org.apache.camel.builder.endpoint.dsl.EventHubsEndpointBuilderFactory.EventHubsBuilders,
org.apache.camel.builder.endpoint.dsl.EventbridgeEndpointBuilderFactory.EventbridgeBuilders,
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 2b0936d1356..c0337a04301 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
@@ -98,6 +98,7 @@ public interface EndpointBuilders
org.apache.camel.builder.endpoint.dsl.EKS2EndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.EhcacheEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.ElasticsearchEndpointBuilderFactory,
+ org.apache.camel.builder.endpoint.dsl.Etcd3EndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.EventEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.EventHubsEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.EventbridgeEndpointBuilderFactory,
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 2030f789417..f27ee5904f7 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
@@ -4278,6 +4278,49 @@ public class StaticEndpointBuilders {
String path) {
return org.apache.camel.builder.endpoint.dsl.ElasticsearchEndpointBuilderFactory.endpointBuilder(componentName, path);
}
+ /**
+ * Etcd v3 (camel-etcd3)
+ * Get, set, delete or watch keys in etcd key-value store.
+ *
+ * Category: clustering,database
+ * Since: 3.19
+ * Maven coordinates: org.apache.camel:camel-etcd3
+ *
+ * Syntax: <code>etcd3:path</code>
+ *
+ * Path parameter: path
+ * The path the endpoint refers to
+ *
+ * @param path path
+ * @return the dsl builder
+ */
+ public static org.apache.camel.builder.endpoint.dsl.Etcd3EndpointBuilderFactory.Etcd3EndpointBuilder etcd3(
+ String path) {
+ return org.apache.camel.builder.endpoint.dsl.Etcd3EndpointBuilderFactory.endpointBuilder("etcd3", path);
+ }
+ /**
+ * Etcd v3 (camel-etcd3)
+ * Get, set, delete or watch keys in etcd key-value store.
+ *
+ * Category: clustering,database
+ * Since: 3.19
+ * Maven coordinates: org.apache.camel:camel-etcd3
+ *
+ * Syntax: <code>etcd3:path</code>
+ *
+ * Path parameter: path
+ * The path the endpoint refers to
+ *
+ * @param componentName to use a custom component name for the endpoint
+ * instead of the default name
+ * @param path path
+ * @return the dsl builder
+ */
+ public static org.apache.camel.builder.endpoint.dsl.Etcd3EndpointBuilderFactory.Etcd3EndpointBuilder etcd3(
+ String componentName,
+ String path) {
+ return org.apache.camel.builder.endpoint.dsl.Etcd3EndpointBuilderFactory.endpointBuilder(componentName, path);
+ }
/**
* Exec (camel-exec)
* Execute commands on the underlying operating system.
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/Etcd3EndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/Etcd3EndpointBuilderFactory.java
new file mode 100644
index 00000000000..968a186cb6e
--- /dev/null
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/Etcd3EndpointBuilderFactory.java
@@ -0,0 +1,1950 @@
+/*
+ * 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.Map;
+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;
+
+/**
+ * Get, set, delete or watch keys in etcd key-value store.
+ *
+ * Generated by camel build tools - do NOT edit this file!
+ */
+@Generated("org.apache.camel.maven.packaging.EndpointDslMojo")
+public interface Etcd3EndpointBuilderFactory {
+
+
+ /**
+ * Builder for endpoint consumers for the Etcd v3 component.
+ */
+ public interface Etcd3EndpointConsumerBuilder
+ extends
+ EndpointConsumerBuilder {
+ default AdvancedEtcd3EndpointConsumerBuilder advanced() {
+ return (AdvancedEtcd3EndpointConsumerBuilder) this;
+ }
+ /**
+ * Configure etcd server endpoints using the IPNameResolver.
+ *
+ * The option is a: <code>java.lang.String[]</code> type.
+ *
+ * Default: Etcd3Constants.ETCD_DEFAULT_ENDPOINTS
+ * Group: common
+ *
+ * @param endpoints the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointConsumerBuilder endpoints(String[] endpoints) {
+ doSetProperty("endpoints", endpoints);
+ return this;
+ }
+ /**
+ * Configure etcd server endpoints using the IPNameResolver.
+ *
+ * The option will be converted to a
+ * <code>java.lang.String[]</code> type.
+ *
+ * Default: Etcd3Constants.ETCD_DEFAULT_ENDPOINTS
+ * Group: common
+ *
+ * @param endpoints the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointConsumerBuilder endpoints(String endpoints) {
+ doSetProperty("endpoints", endpoints);
+ return this;
+ }
+ /**
+ * Configure the charset to use for the keys.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: UTF-8
+ * Group: common
+ *
+ * @param keyCharset the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointConsumerBuilder keyCharset(String keyCharset) {
+ doSetProperty("keyCharset", keyCharset);
+ return this;
+ }
+ /**
+ * Configure the namespace of keys used. / will be treated as no
+ * namespace.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param namespace the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointConsumerBuilder namespace(String namespace) {
+ doSetProperty("namespace", namespace);
+ return this;
+ }
+ /**
+ * To apply an action on all the key-value pairs whose key that starts
+ * with the target path.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: common
+ *
+ * @param prefix the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointConsumerBuilder prefix(boolean prefix) {
+ doSetProperty("prefix", prefix);
+ return this;
+ }
+ /**
+ * To apply an action on all the key-value pairs whose key that starts
+ * with the target path.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: common
+ *
+ * @param prefix the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointConsumerBuilder prefix(String prefix) {
+ doSetProperty("prefix", prefix);
+ return this;
+ }
+ /**
+ * The path to look for service discovery.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: /services/
+ * Group: cloud
+ *
+ * @param servicePath the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointConsumerBuilder servicePath(String servicePath) {
+ doSetProperty("servicePath", servicePath);
+ return this;
+ }
+ /**
+ * Configure etcd auth password.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param password the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointConsumerBuilder password(String password) {
+ doSetProperty("password", password);
+ return this;
+ }
+ /**
+ * Configure etcd auth user.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param userName the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointConsumerBuilder userName(String userName) {
+ doSetProperty("userName", userName);
+ return this;
+ }
+ }
+
+ /**
+ * Advanced builder for endpoint consumers for the Etcd v3 component.
+ */
+ public interface AdvancedEtcd3EndpointConsumerBuilder
+ extends
+ EndpointConsumerBuilder {
+ default Etcd3EndpointConsumerBuilder basic() {
+ return (Etcd3EndpointConsumerBuilder) this;
+ }
+ /**
+ * Allows for bridging the consumer to the Camel routing Error Handler,
+ * which mean any exceptions occurred while the consumer is trying to
+ * pickup incoming messages, or the likes, will now be processed as a
+ * message and handled by the routing Error Handler. By default the
+ * consumer will use the org.apache.camel.spi.ExceptionHandler to deal
+ * with exceptions, that will be logged at WARN or ERROR level and
+ * ignored.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: consumer (advanced)
+ *
+ * @param bridgeErrorHandler the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder bridgeErrorHandler(
+ boolean bridgeErrorHandler) {
+ doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
+ return this;
+ }
+ /**
+ * Allows for bridging the consumer to the Camel routing Error Handler,
+ * which mean any exceptions occurred while the consumer is trying to
+ * pickup incoming messages, or the likes, will now be processed as a
+ * message and handled by the routing Error Handler. By default the
+ * consumer will use the org.apache.camel.spi.ExceptionHandler to deal
+ * with exceptions, that will be logged at WARN or ERROR level and
+ * ignored.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: consumer (advanced)
+ *
+ * @param bridgeErrorHandler the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder bridgeErrorHandler(
+ String bridgeErrorHandler) {
+ doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
+ return this;
+ }
+ /**
+ * To let the consumer use a custom ExceptionHandler. Notice if the
+ * option bridgeErrorHandler is enabled then this option is not in use.
+ * By default the consumer will deal with exceptions, that will be
+ * logged at WARN or ERROR level and ignored.
+ *
+ * The option is a:
+ * <code>org.apache.camel.spi.ExceptionHandler</code> type.
+ *
+ * Group: consumer (advanced)
+ *
+ * @param exceptionHandler the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder exceptionHandler(
+ org.apache.camel.spi.ExceptionHandler exceptionHandler) {
+ doSetProperty("exceptionHandler", exceptionHandler);
+ return this;
+ }
+ /**
+ * To let the consumer use a custom ExceptionHandler. Notice if the
+ * option bridgeErrorHandler is enabled then this option is not in use.
+ * By default the consumer will deal with exceptions, that will be
+ * logged at WARN or ERROR level and ignored.
+ *
+ * The option will be converted to a
+ * <code>org.apache.camel.spi.ExceptionHandler</code> type.
+ *
+ * Group: consumer (advanced)
+ *
+ * @param exceptionHandler the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder exceptionHandler(
+ String exceptionHandler) {
+ doSetProperty("exceptionHandler", exceptionHandler);
+ return this;
+ }
+ /**
+ * Sets the exchange pattern when the consumer creates an exchange.
+ *
+ * The option is a:
+ * <code>org.apache.camel.ExchangePattern</code> type.
+ *
+ * Group: consumer (advanced)
+ *
+ * @param exchangePattern the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder exchangePattern(
+ org.apache.camel.ExchangePattern exchangePattern) {
+ doSetProperty("exchangePattern", exchangePattern);
+ return this;
+ }
+ /**
+ * Sets the exchange pattern when the consumer creates an exchange.
+ *
+ * The option will be converted to a
+ * <code>org.apache.camel.ExchangePattern</code> type.
+ *
+ * Group: consumer (advanced)
+ *
+ * @param exchangePattern the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder exchangePattern(
+ String exchangePattern) {
+ doSetProperty("exchangePattern", exchangePattern);
+ return this;
+ }
+ /**
+ * The index to watch from.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 0
+ * Group: consumer (advanced)
+ *
+ * @param fromIndex the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder fromIndex(long fromIndex) {
+ doSetProperty("fromIndex", fromIndex);
+ return this;
+ }
+ /**
+ * The index to watch from.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 0
+ * Group: consumer (advanced)
+ *
+ * @param fromIndex the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder fromIndex(String fromIndex) {
+ doSetProperty("fromIndex", fromIndex);
+ return this;
+ }
+ /**
+ * Configure the headers to be added to auth request headers.
+ *
+ * The option is a: <code>java.util.Map&lt;java.lang.String,
+ * java.lang.String&gt;</code> type.
+ * The option is multivalued, and you can use the authHeaders(String,
+ * Object) method to add a value (call the method multiple times to set
+ * more values).
+ *
+ * Group: advanced
+ *
+ * @param key the option key
+ * @param value the option value
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder authHeaders(
+ String key,
+ Object value) {
+ doSetMultiValueProperty("authHeaders", "authHeaders." + key, value);
+ return this;
+ }
+ /**
+ * Configure the headers to be added to auth request headers.
+ *
+ * The option is a: <code>java.util.Map&lt;java.lang.String,
+ * java.lang.String&gt;</code> type.
+ * The option is multivalued, and you can use the authHeaders(String,
+ * Object) method to add a value (call the method multiple times to set
+ * more values).
+ *
+ * Group: advanced
+ *
+ * @param values the values
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder authHeaders(Map values) {
+ doSetMultiValueProperties("authHeaders", "authHeaders.", values);
+ return this;
+ }
+ /**
+ * Configure the authority used to authenticate connections to servers.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: advanced
+ *
+ * @param authority the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder authority(String authority) {
+ doSetProperty("authority", authority);
+ return this;
+ }
+ /**
+ * Configure the connection timeout.
+ *
+ * The option is a: <code>java.time.Duration</code> type.
+ *
+ * Group: advanced
+ *
+ * @param connectionTimeout the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder connectionTimeout(
+ java.time.Duration connectionTimeout) {
+ doSetProperty("connectionTimeout", connectionTimeout);
+ return this;
+ }
+ /**
+ * Configure the connection timeout.
+ *
+ * The option will be converted to a
+ * <code>java.time.Duration</code> type.
+ *
+ * Group: advanced
+ *
+ * @param connectionTimeout the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder connectionTimeout(
+ String connectionTimeout) {
+ doSetProperty("connectionTimeout", connectionTimeout);
+ return this;
+ }
+ /**
+ * Configure the headers to be added to http request headers.
+ *
+ * The option is a: <code>java.util.Map&lt;java.lang.String,
+ * java.lang.String&gt;</code> type.
+ * The option is multivalued, and you can use the headers(String,
+ * Object) method to add a value (call the method multiple times to set
+ * more values).
+ *
+ * Group: advanced
+ *
+ * @param key the option key
+ * @param value the option value
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder headers(
+ String key,
+ Object value) {
+ doSetMultiValueProperty("headers", "headers." + key, value);
+ return this;
+ }
+ /**
+ * Configure the headers to be added to http request headers.
+ *
+ * The option is a: <code>java.util.Map&lt;java.lang.String,
+ * java.lang.String&gt;</code> type.
+ * The option is multivalued, and you can use the headers(String,
+ * Object) method to add a value (call the method multiple times to set
+ * more values).
+ *
+ * Group: advanced
+ *
+ * @param values the values
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder headers(Map values) {
+ doSetMultiValueProperties("headers", "headers.", values);
+ return this;
+ }
+ /**
+ * Configure the interval for gRPC keepalives. The current minimum
+ * allowed by gRPC is 10 seconds.
+ *
+ * The option is a: <code>java.time.Duration</code> type.
+ *
+ * Default: 30 seconds
+ * Group: advanced
+ *
+ * @param keepAliveTime the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder keepAliveTime(
+ java.time.Duration keepAliveTime) {
+ doSetProperty("keepAliveTime", keepAliveTime);
+ return this;
+ }
+ /**
+ * Configure the interval for gRPC keepalives. The current minimum
+ * allowed by gRPC is 10 seconds.
+ *
+ * The option will be converted to a
+ * <code>java.time.Duration</code> type.
+ *
+ * Default: 30 seconds
+ * Group: advanced
+ *
+ * @param keepAliveTime the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder keepAliveTime(
+ String keepAliveTime) {
+ doSetProperty("keepAliveTime", keepAliveTime);
+ return this;
+ }
+ /**
+ * Configure the timeout for gRPC keepalives.
+ *
+ * The option is a: <code>java.time.Duration</code> type.
+ *
+ * Default: 10 seconds
+ * Group: advanced
+ *
+ * @param keepAliveTimeout the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder keepAliveTimeout(
+ java.time.Duration keepAliveTimeout) {
+ doSetProperty("keepAliveTimeout", keepAliveTimeout);
+ return this;
+ }
+ /**
+ * Configure the timeout for gRPC keepalives.
+ *
+ * The option will be converted to a
+ * <code>java.time.Duration</code> type.
+ *
+ * Default: 10 seconds
+ * Group: advanced
+ *
+ * @param keepAliveTimeout the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder keepAliveTimeout(
+ String keepAliveTimeout) {
+ doSetProperty("keepAliveTimeout", keepAliveTimeout);
+ return this;
+ }
+ /**
+ * Configure etcd load balancer policy.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: advanced
+ *
+ * @param loadBalancerPolicy the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder loadBalancerPolicy(
+ String loadBalancerPolicy) {
+ doSetProperty("loadBalancerPolicy", loadBalancerPolicy);
+ return this;
+ }
+ /**
+ * Configure the maximum message size allowed for a single gRPC frame.
+ *
+ * The option is a: <code>java.lang.Integer</code> type.
+ *
+ * Group: advanced
+ *
+ * @param maxInboundMessageSize the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder maxInboundMessageSize(
+ Integer maxInboundMessageSize) {
+ doSetProperty("maxInboundMessageSize", maxInboundMessageSize);
+ return this;
+ }
+ /**
+ * Configure the maximum message size allowed for a single gRPC frame.
+ *
+ * The option will be converted to a
+ * <code>java.lang.Integer</code> type.
+ *
+ * Group: advanced
+ *
+ * @param maxInboundMessageSize the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder maxInboundMessageSize(
+ String maxInboundMessageSize) {
+ doSetProperty("maxInboundMessageSize", maxInboundMessageSize);
+ return this;
+ }
+ /**
+ * Configure the delay between retries in milliseconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 500
+ * Group: advanced
+ *
+ * @param retryDelay the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder retryDelay(long retryDelay) {
+ doSetProperty("retryDelay", retryDelay);
+ return this;
+ }
+ /**
+ * Configure the delay between retries in milliseconds.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 500
+ * Group: advanced
+ *
+ * @param retryDelay the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder retryDelay(
+ String retryDelay) {
+ doSetProperty("retryDelay", retryDelay);
+ return this;
+ }
+ /**
+ * Configure the max backing off delay between retries in milliseconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 2500
+ * Group: advanced
+ *
+ * @param retryMaxDelay the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder retryMaxDelay(
+ long retryMaxDelay) {
+ doSetProperty("retryMaxDelay", retryMaxDelay);
+ return this;
+ }
+ /**
+ * Configure the max backing off delay between retries in milliseconds.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 2500
+ * Group: advanced
+ *
+ * @param retryMaxDelay the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder retryMaxDelay(
+ String retryMaxDelay) {
+ doSetProperty("retryMaxDelay", retryMaxDelay);
+ return this;
+ }
+ /**
+ * Configure the retries max duration.
+ *
+ * The option is a: <code>java.time.Duration</code> type.
+ *
+ * Group: advanced
+ *
+ * @param retryMaxDuration the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder retryMaxDuration(
+ java.time.Duration retryMaxDuration) {
+ doSetProperty("retryMaxDuration", retryMaxDuration);
+ return this;
+ }
+ /**
+ * Configure the retries max duration.
+ *
+ * The option will be converted to a
+ * <code>java.time.Duration</code> type.
+ *
+ * Group: advanced
+ *
+ * @param retryMaxDuration the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder retryMaxDuration(
+ String retryMaxDuration) {
+ doSetProperty("retryMaxDuration", retryMaxDuration);
+ return this;
+ }
+ /**
+ * Configure SSL/TLS context to use instead of the system default.
+ *
+ * The option is a:
+ * <code>io.netty.handler.ssl.SslContext</code> type.
+ *
+ * Group: security
+ *
+ * @param sslContext the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder sslContext(
+ io.netty.handler.ssl.SslContext sslContext) {
+ doSetProperty("sslContext", sslContext);
+ return this;
+ }
+ /**
+ * Configure SSL/TLS context to use instead of the system default.
+ *
+ * The option will be converted to a
+ * <code>io.netty.handler.ssl.SslContext</code> type.
+ *
+ * Group: security
+ *
+ * @param sslContext the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointConsumerBuilder sslContext(
+ String sslContext) {
+ doSetProperty("sslContext", sslContext);
+ return this;
+ }
+ }
+
+ /**
+ * Builder for endpoint producers for the Etcd v3 component.
+ */
+ public interface Etcd3EndpointProducerBuilder
+ extends
+ EndpointProducerBuilder {
+ default AdvancedEtcd3EndpointProducerBuilder advanced() {
+ return (AdvancedEtcd3EndpointProducerBuilder) this;
+ }
+ /**
+ * Configure etcd server endpoints using the IPNameResolver.
+ *
+ * The option is a: <code>java.lang.String[]</code> type.
+ *
+ * Default: Etcd3Constants.ETCD_DEFAULT_ENDPOINTS
+ * Group: common
+ *
+ * @param endpoints the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointProducerBuilder endpoints(String[] endpoints) {
+ doSetProperty("endpoints", endpoints);
+ return this;
+ }
+ /**
+ * Configure etcd server endpoints using the IPNameResolver.
+ *
+ * The option will be converted to a
+ * <code>java.lang.String[]</code> type.
+ *
+ * Default: Etcd3Constants.ETCD_DEFAULT_ENDPOINTS
+ * Group: common
+ *
+ * @param endpoints the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointProducerBuilder endpoints(String endpoints) {
+ doSetProperty("endpoints", endpoints);
+ return this;
+ }
+ /**
+ * Configure the charset to use for the keys.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: UTF-8
+ * Group: common
+ *
+ * @param keyCharset the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointProducerBuilder keyCharset(String keyCharset) {
+ doSetProperty("keyCharset", keyCharset);
+ return this;
+ }
+ /**
+ * Configure the namespace of keys used. / will be treated as no
+ * namespace.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param namespace the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointProducerBuilder namespace(String namespace) {
+ doSetProperty("namespace", namespace);
+ return this;
+ }
+ /**
+ * To apply an action on all the key-value pairs whose key that starts
+ * with the target path.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: common
+ *
+ * @param prefix the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointProducerBuilder prefix(boolean prefix) {
+ doSetProperty("prefix", prefix);
+ return this;
+ }
+ /**
+ * To apply an action on all the key-value pairs whose key that starts
+ * with the target path.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: common
+ *
+ * @param prefix the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointProducerBuilder prefix(String prefix) {
+ doSetProperty("prefix", prefix);
+ return this;
+ }
+ /**
+ * Configure the charset to use for the values.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: UTF-8
+ * Group: producer
+ *
+ * @param valueCharset the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointProducerBuilder valueCharset(String valueCharset) {
+ doSetProperty("valueCharset", valueCharset);
+ return this;
+ }
+ /**
+ * The path to look for service discovery.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: /services/
+ * Group: cloud
+ *
+ * @param servicePath the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointProducerBuilder servicePath(String servicePath) {
+ doSetProperty("servicePath", servicePath);
+ return this;
+ }
+ /**
+ * Configure etcd auth password.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param password the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointProducerBuilder password(String password) {
+ doSetProperty("password", password);
+ return this;
+ }
+ /**
+ * Configure etcd auth user.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param userName the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointProducerBuilder userName(String userName) {
+ doSetProperty("userName", userName);
+ return this;
+ }
+ }
+
+ /**
+ * Advanced builder for endpoint producers for the Etcd v3 component.
+ */
+ public interface AdvancedEtcd3EndpointProducerBuilder
+ extends
+ EndpointProducerBuilder {
+ default Etcd3EndpointProducerBuilder basic() {
+ return (Etcd3EndpointProducerBuilder) 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 AdvancedEtcd3EndpointProducerBuilder 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 AdvancedEtcd3EndpointProducerBuilder lazyStartProducer(
+ String lazyStartProducer) {
+ doSetProperty("lazyStartProducer", lazyStartProducer);
+ return this;
+ }
+ /**
+ * Configure the headers to be added to auth request headers.
+ *
+ * The option is a: <code>java.util.Map&lt;java.lang.String,
+ * java.lang.String&gt;</code> type.
+ * The option is multivalued, and you can use the authHeaders(String,
+ * Object) method to add a value (call the method multiple times to set
+ * more values).
+ *
+ * Group: advanced
+ *
+ * @param key the option key
+ * @param value the option value
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointProducerBuilder authHeaders(
+ String key,
+ Object value) {
+ doSetMultiValueProperty("authHeaders", "authHeaders." + key, value);
+ return this;
+ }
+ /**
+ * Configure the headers to be added to auth request headers.
+ *
+ * The option is a: <code>java.util.Map&lt;java.lang.String,
+ * java.lang.String&gt;</code> type.
+ * The option is multivalued, and you can use the authHeaders(String,
+ * Object) method to add a value (call the method multiple times to set
+ * more values).
+ *
+ * Group: advanced
+ *
+ * @param values the values
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointProducerBuilder authHeaders(Map values) {
+ doSetMultiValueProperties("authHeaders", "authHeaders.", values);
+ return this;
+ }
+ /**
+ * Configure the authority used to authenticate connections to servers.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: advanced
+ *
+ * @param authority the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointProducerBuilder authority(String authority) {
+ doSetProperty("authority", authority);
+ return this;
+ }
+ /**
+ * Configure the connection timeout.
+ *
+ * The option is a: <code>java.time.Duration</code> type.
+ *
+ * Group: advanced
+ *
+ * @param connectionTimeout the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointProducerBuilder connectionTimeout(
+ java.time.Duration connectionTimeout) {
+ doSetProperty("connectionTimeout", connectionTimeout);
+ return this;
+ }
+ /**
+ * Configure the connection timeout.
+ *
+ * The option will be converted to a
+ * <code>java.time.Duration</code> type.
+ *
+ * Group: advanced
+ *
+ * @param connectionTimeout the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointProducerBuilder connectionTimeout(
+ String connectionTimeout) {
+ doSetProperty("connectionTimeout", connectionTimeout);
+ return this;
+ }
+ /**
+ * Configure the headers to be added to http request headers.
+ *
+ * The option is a: <code>java.util.Map&lt;java.lang.String,
+ * java.lang.String&gt;</code> type.
+ * The option is multivalued, and you can use the headers(String,
+ * Object) method to add a value (call the method multiple times to set
+ * more values).
+ *
+ * Group: advanced
+ *
+ * @param key the option key
+ * @param value the option value
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointProducerBuilder headers(
+ String key,
+ Object value) {
+ doSetMultiValueProperty("headers", "headers." + key, value);
+ return this;
+ }
+ /**
+ * Configure the headers to be added to http request headers.
+ *
+ * The option is a: <code>java.util.Map&lt;java.lang.String,
+ * java.lang.String&gt;</code> type.
+ * The option is multivalued, and you can use the headers(String,
+ * Object) method to add a value (call the method multiple times to set
+ * more values).
+ *
+ * Group: advanced
+ *
+ * @param values the values
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointProducerBuilder headers(Map values) {
+ doSetMultiValueProperties("headers", "headers.", values);
+ return this;
+ }
+ /**
+ * Configure the interval for gRPC keepalives. The current minimum
+ * allowed by gRPC is 10 seconds.
+ *
+ * The option is a: <code>java.time.Duration</code> type.
+ *
+ * Default: 30 seconds
+ * Group: advanced
+ *
+ * @param keepAliveTime the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointProducerBuilder keepAliveTime(
+ java.time.Duration keepAliveTime) {
+ doSetProperty("keepAliveTime", keepAliveTime);
+ return this;
+ }
+ /**
+ * Configure the interval for gRPC keepalives. The current minimum
+ * allowed by gRPC is 10 seconds.
+ *
+ * The option will be converted to a
+ * <code>java.time.Duration</code> type.
+ *
+ * Default: 30 seconds
+ * Group: advanced
+ *
+ * @param keepAliveTime the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointProducerBuilder keepAliveTime(
+ String keepAliveTime) {
+ doSetProperty("keepAliveTime", keepAliveTime);
+ return this;
+ }
+ /**
+ * Configure the timeout for gRPC keepalives.
+ *
+ * The option is a: <code>java.time.Duration</code> type.
+ *
+ * Default: 10 seconds
+ * Group: advanced
+ *
+ * @param keepAliveTimeout the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointProducerBuilder keepAliveTimeout(
+ java.time.Duration keepAliveTimeout) {
+ doSetProperty("keepAliveTimeout", keepAliveTimeout);
+ return this;
+ }
+ /**
+ * Configure the timeout for gRPC keepalives.
+ *
+ * The option will be converted to a
+ * <code>java.time.Duration</code> type.
+ *
+ * Default: 10 seconds
+ * Group: advanced
+ *
+ * @param keepAliveTimeout the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointProducerBuilder keepAliveTimeout(
+ String keepAliveTimeout) {
+ doSetProperty("keepAliveTimeout", keepAliveTimeout);
+ return this;
+ }
+ /**
+ * Configure etcd load balancer policy.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: advanced
+ *
+ * @param loadBalancerPolicy the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointProducerBuilder loadBalancerPolicy(
+ String loadBalancerPolicy) {
+ doSetProperty("loadBalancerPolicy", loadBalancerPolicy);
+ return this;
+ }
+ /**
+ * Configure the maximum message size allowed for a single gRPC frame.
+ *
+ * The option is a: <code>java.lang.Integer</code> type.
+ *
+ * Group: advanced
+ *
+ * @param maxInboundMessageSize the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointProducerBuilder maxInboundMessageSize(
+ Integer maxInboundMessageSize) {
+ doSetProperty("maxInboundMessageSize", maxInboundMessageSize);
+ return this;
+ }
+ /**
+ * Configure the maximum message size allowed for a single gRPC frame.
+ *
+ * The option will be converted to a
+ * <code>java.lang.Integer</code> type.
+ *
+ * Group: advanced
+ *
+ * @param maxInboundMessageSize the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointProducerBuilder maxInboundMessageSize(
+ String maxInboundMessageSize) {
+ doSetProperty("maxInboundMessageSize", maxInboundMessageSize);
+ return this;
+ }
+ /**
+ * Configure the delay between retries in milliseconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 500
+ * Group: advanced
+ *
+ * @param retryDelay the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointProducerBuilder retryDelay(long retryDelay) {
+ doSetProperty("retryDelay", retryDelay);
+ return this;
+ }
+ /**
+ * Configure the delay between retries in milliseconds.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 500
+ * Group: advanced
+ *
+ * @param retryDelay the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointProducerBuilder retryDelay(
+ String retryDelay) {
+ doSetProperty("retryDelay", retryDelay);
+ return this;
+ }
+ /**
+ * Configure the max backing off delay between retries in milliseconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 2500
+ * Group: advanced
+ *
+ * @param retryMaxDelay the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointProducerBuilder retryMaxDelay(
+ long retryMaxDelay) {
+ doSetProperty("retryMaxDelay", retryMaxDelay);
+ return this;
+ }
+ /**
+ * Configure the max backing off delay between retries in milliseconds.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 2500
+ * Group: advanced
+ *
+ * @param retryMaxDelay the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointProducerBuilder retryMaxDelay(
+ String retryMaxDelay) {
+ doSetProperty("retryMaxDelay", retryMaxDelay);
+ return this;
+ }
+ /**
+ * Configure the retries max duration.
+ *
+ * The option is a: <code>java.time.Duration</code> type.
+ *
+ * Group: advanced
+ *
+ * @param retryMaxDuration the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointProducerBuilder retryMaxDuration(
+ java.time.Duration retryMaxDuration) {
+ doSetProperty("retryMaxDuration", retryMaxDuration);
+ return this;
+ }
+ /**
+ * Configure the retries max duration.
+ *
+ * The option will be converted to a
+ * <code>java.time.Duration</code> type.
+ *
+ * Group: advanced
+ *
+ * @param retryMaxDuration the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointProducerBuilder retryMaxDuration(
+ String retryMaxDuration) {
+ doSetProperty("retryMaxDuration", retryMaxDuration);
+ return this;
+ }
+ /**
+ * Configure SSL/TLS context to use instead of the system default.
+ *
+ * The option is a:
+ * <code>io.netty.handler.ssl.SslContext</code> type.
+ *
+ * Group: security
+ *
+ * @param sslContext the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointProducerBuilder sslContext(
+ io.netty.handler.ssl.SslContext sslContext) {
+ doSetProperty("sslContext", sslContext);
+ return this;
+ }
+ /**
+ * Configure SSL/TLS context to use instead of the system default.
+ *
+ * The option will be converted to a
+ * <code>io.netty.handler.ssl.SslContext</code> type.
+ *
+ * Group: security
+ *
+ * @param sslContext the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointProducerBuilder sslContext(
+ String sslContext) {
+ doSetProperty("sslContext", sslContext);
+ return this;
+ }
+ }
+
+ /**
+ * Builder for endpoint for the Etcd v3 component.
+ */
+ public interface Etcd3EndpointBuilder
+ extends
+ Etcd3EndpointConsumerBuilder,
+ Etcd3EndpointProducerBuilder {
+ default AdvancedEtcd3EndpointBuilder advanced() {
+ return (AdvancedEtcd3EndpointBuilder) this;
+ }
+ /**
+ * Configure etcd server endpoints using the IPNameResolver.
+ *
+ * The option is a: <code>java.lang.String[]</code> type.
+ *
+ * Default: Etcd3Constants.ETCD_DEFAULT_ENDPOINTS
+ * Group: common
+ *
+ * @param endpoints the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointBuilder endpoints(String[] endpoints) {
+ doSetProperty("endpoints", endpoints);
+ return this;
+ }
+ /**
+ * Configure etcd server endpoints using the IPNameResolver.
+ *
+ * The option will be converted to a
+ * <code>java.lang.String[]</code> type.
+ *
+ * Default: Etcd3Constants.ETCD_DEFAULT_ENDPOINTS
+ * Group: common
+ *
+ * @param endpoints the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointBuilder endpoints(String endpoints) {
+ doSetProperty("endpoints", endpoints);
+ return this;
+ }
+ /**
+ * Configure the charset to use for the keys.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: UTF-8
+ * Group: common
+ *
+ * @param keyCharset the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointBuilder keyCharset(String keyCharset) {
+ doSetProperty("keyCharset", keyCharset);
+ return this;
+ }
+ /**
+ * Configure the namespace of keys used. / will be treated as no
+ * namespace.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param namespace the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointBuilder namespace(String namespace) {
+ doSetProperty("namespace", namespace);
+ return this;
+ }
+ /**
+ * To apply an action on all the key-value pairs whose key that starts
+ * with the target path.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: common
+ *
+ * @param prefix the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointBuilder prefix(boolean prefix) {
+ doSetProperty("prefix", prefix);
+ return this;
+ }
+ /**
+ * To apply an action on all the key-value pairs whose key that starts
+ * with the target path.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: common
+ *
+ * @param prefix the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointBuilder prefix(String prefix) {
+ doSetProperty("prefix", prefix);
+ return this;
+ }
+ /**
+ * The path to look for service discovery.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: /services/
+ * Group: cloud
+ *
+ * @param servicePath the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointBuilder servicePath(String servicePath) {
+ doSetProperty("servicePath", servicePath);
+ return this;
+ }
+ /**
+ * Configure etcd auth password.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param password the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointBuilder password(String password) {
+ doSetProperty("password", password);
+ return this;
+ }
+ /**
+ * Configure etcd auth user.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param userName the value to set
+ * @return the dsl builder
+ */
+ default Etcd3EndpointBuilder userName(String userName) {
+ doSetProperty("userName", userName);
+ return this;
+ }
+ }
+
+ /**
+ * Advanced builder for endpoint for the Etcd v3 component.
+ */
+ public interface AdvancedEtcd3EndpointBuilder
+ extends
+ AdvancedEtcd3EndpointConsumerBuilder,
+ AdvancedEtcd3EndpointProducerBuilder {
+ default Etcd3EndpointBuilder basic() {
+ return (Etcd3EndpointBuilder) this;
+ }
+ /**
+ * Configure the headers to be added to auth request headers.
+ *
+ * The option is a: <code>java.util.Map&lt;java.lang.String,
+ * java.lang.String&gt;</code> type.
+ * The option is multivalued, and you can use the authHeaders(String,
+ * Object) method to add a value (call the method multiple times to set
+ * more values).
+ *
+ * Group: advanced
+ *
+ * @param key the option key
+ * @param value the option value
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointBuilder authHeaders(
+ String key,
+ Object value) {
+ doSetMultiValueProperty("authHeaders", "authHeaders." + key, value);
+ return this;
+ }
+ /**
+ * Configure the headers to be added to auth request headers.
+ *
+ * The option is a: <code>java.util.Map&lt;java.lang.String,
+ * java.lang.String&gt;</code> type.
+ * The option is multivalued, and you can use the authHeaders(String,
+ * Object) method to add a value (call the method multiple times to set
+ * more values).
+ *
+ * Group: advanced
+ *
+ * @param values the values
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointBuilder authHeaders(Map values) {
+ doSetMultiValueProperties("authHeaders", "authHeaders.", values);
+ return this;
+ }
+ /**
+ * Configure the authority used to authenticate connections to servers.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: advanced
+ *
+ * @param authority the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointBuilder authority(String authority) {
+ doSetProperty("authority", authority);
+ return this;
+ }
+ /**
+ * Configure the connection timeout.
+ *
+ * The option is a: <code>java.time.Duration</code> type.
+ *
+ * Group: advanced
+ *
+ * @param connectionTimeout the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointBuilder connectionTimeout(
+ java.time.Duration connectionTimeout) {
+ doSetProperty("connectionTimeout", connectionTimeout);
+ return this;
+ }
+ /**
+ * Configure the connection timeout.
+ *
+ * The option will be converted to a
+ * <code>java.time.Duration</code> type.
+ *
+ * Group: advanced
+ *
+ * @param connectionTimeout the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointBuilder connectionTimeout(
+ String connectionTimeout) {
+ doSetProperty("connectionTimeout", connectionTimeout);
+ return this;
+ }
+ /**
+ * Configure the headers to be added to http request headers.
+ *
+ * The option is a: <code>java.util.Map&lt;java.lang.String,
+ * java.lang.String&gt;</code> type.
+ * The option is multivalued, and you can use the headers(String,
+ * Object) method to add a value (call the method multiple times to set
+ * more values).
+ *
+ * Group: advanced
+ *
+ * @param key the option key
+ * @param value the option value
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointBuilder headers(String key, Object value) {
+ doSetMultiValueProperty("headers", "headers." + key, value);
+ return this;
+ }
+ /**
+ * Configure the headers to be added to http request headers.
+ *
+ * The option is a: <code>java.util.Map&lt;java.lang.String,
+ * java.lang.String&gt;</code> type.
+ * The option is multivalued, and you can use the headers(String,
+ * Object) method to add a value (call the method multiple times to set
+ * more values).
+ *
+ * Group: advanced
+ *
+ * @param values the values
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointBuilder headers(Map values) {
+ doSetMultiValueProperties("headers", "headers.", values);
+ return this;
+ }
+ /**
+ * Configure the interval for gRPC keepalives. The current minimum
+ * allowed by gRPC is 10 seconds.
+ *
+ * The option is a: <code>java.time.Duration</code> type.
+ *
+ * Default: 30 seconds
+ * Group: advanced
+ *
+ * @param keepAliveTime the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointBuilder keepAliveTime(
+ java.time.Duration keepAliveTime) {
+ doSetProperty("keepAliveTime", keepAliveTime);
+ return this;
+ }
+ /**
+ * Configure the interval for gRPC keepalives. The current minimum
+ * allowed by gRPC is 10 seconds.
+ *
+ * The option will be converted to a
+ * <code>java.time.Duration</code> type.
+ *
+ * Default: 30 seconds
+ * Group: advanced
+ *
+ * @param keepAliveTime the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointBuilder keepAliveTime(String keepAliveTime) {
+ doSetProperty("keepAliveTime", keepAliveTime);
+ return this;
+ }
+ /**
+ * Configure the timeout for gRPC keepalives.
+ *
+ * The option is a: <code>java.time.Duration</code> type.
+ *
+ * Default: 10 seconds
+ * Group: advanced
+ *
+ * @param keepAliveTimeout the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointBuilder keepAliveTimeout(
+ java.time.Duration keepAliveTimeout) {
+ doSetProperty("keepAliveTimeout", keepAliveTimeout);
+ return this;
+ }
+ /**
+ * Configure the timeout for gRPC keepalives.
+ *
+ * The option will be converted to a
+ * <code>java.time.Duration</code> type.
+ *
+ * Default: 10 seconds
+ * Group: advanced
+ *
+ * @param keepAliveTimeout the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointBuilder keepAliveTimeout(
+ String keepAliveTimeout) {
+ doSetProperty("keepAliveTimeout", keepAliveTimeout);
+ return this;
+ }
+ /**
+ * Configure etcd load balancer policy.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: advanced
+ *
+ * @param loadBalancerPolicy the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointBuilder loadBalancerPolicy(
+ String loadBalancerPolicy) {
+ doSetProperty("loadBalancerPolicy", loadBalancerPolicy);
+ return this;
+ }
+ /**
+ * Configure the maximum message size allowed for a single gRPC frame.
+ *
+ * The option is a: <code>java.lang.Integer</code> type.
+ *
+ * Group: advanced
+ *
+ * @param maxInboundMessageSize the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointBuilder maxInboundMessageSize(
+ Integer maxInboundMessageSize) {
+ doSetProperty("maxInboundMessageSize", maxInboundMessageSize);
+ return this;
+ }
+ /**
+ * Configure the maximum message size allowed for a single gRPC frame.
+ *
+ * The option will be converted to a
+ * <code>java.lang.Integer</code> type.
+ *
+ * Group: advanced
+ *
+ * @param maxInboundMessageSize the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointBuilder maxInboundMessageSize(
+ String maxInboundMessageSize) {
+ doSetProperty("maxInboundMessageSize", maxInboundMessageSize);
+ return this;
+ }
+ /**
+ * Configure the delay between retries in milliseconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 500
+ * Group: advanced
+ *
+ * @param retryDelay the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointBuilder retryDelay(long retryDelay) {
+ doSetProperty("retryDelay", retryDelay);
+ return this;
+ }
+ /**
+ * Configure the delay between retries in milliseconds.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 500
+ * Group: advanced
+ *
+ * @param retryDelay the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointBuilder retryDelay(String retryDelay) {
+ doSetProperty("retryDelay", retryDelay);
+ return this;
+ }
+ /**
+ * Configure the max backing off delay between retries in milliseconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 2500
+ * Group: advanced
+ *
+ * @param retryMaxDelay the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointBuilder retryMaxDelay(long retryMaxDelay) {
+ doSetProperty("retryMaxDelay", retryMaxDelay);
+ return this;
+ }
+ /**
+ * Configure the max backing off delay between retries in milliseconds.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 2500
+ * Group: advanced
+ *
+ * @param retryMaxDelay the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointBuilder retryMaxDelay(String retryMaxDelay) {
+ doSetProperty("retryMaxDelay", retryMaxDelay);
+ return this;
+ }
+ /**
+ * Configure the retries max duration.
+ *
+ * The option is a: <code>java.time.Duration</code> type.
+ *
+ * Group: advanced
+ *
+ * @param retryMaxDuration the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointBuilder retryMaxDuration(
+ java.time.Duration retryMaxDuration) {
+ doSetProperty("retryMaxDuration", retryMaxDuration);
+ return this;
+ }
+ /**
+ * Configure the retries max duration.
+ *
+ * The option will be converted to a
+ * <code>java.time.Duration</code> type.
+ *
+ * Group: advanced
+ *
+ * @param retryMaxDuration the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointBuilder retryMaxDuration(
+ String retryMaxDuration) {
+ doSetProperty("retryMaxDuration", retryMaxDuration);
+ return this;
+ }
+ /**
+ * Configure SSL/TLS context to use instead of the system default.
+ *
+ * The option is a:
+ * <code>io.netty.handler.ssl.SslContext</code> type.
+ *
+ * Group: security
+ *
+ * @param sslContext the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointBuilder sslContext(
+ io.netty.handler.ssl.SslContext sslContext) {
+ doSetProperty("sslContext", sslContext);
+ return this;
+ }
+ /**
+ * Configure SSL/TLS context to use instead of the system default.
+ *
+ * The option will be converted to a
+ * <code>io.netty.handler.ssl.SslContext</code> type.
+ *
+ * Group: security
+ *
+ * @param sslContext the value to set
+ * @return the dsl builder
+ */
+ default AdvancedEtcd3EndpointBuilder sslContext(String sslContext) {
+ doSetProperty("sslContext", sslContext);
+ return this;
+ }
+ }
+
+ public interface Etcd3Builders {
+ /**
+ * Etcd v3 (camel-etcd3)
+ * Get, set, delete or watch keys in etcd key-value store.
+ *
+ * Category: clustering,database
+ * Since: 3.19
+ * Maven coordinates: org.apache.camel:camel-etcd3
+ *
+ * @return the dsl builder for the headers' name.
+ */
+ default Etcd3HeaderNameBuilder etcd3() {
+ return Etcd3HeaderNameBuilder.INSTANCE;
+ }
+ /**
+ * Etcd v3 (camel-etcd3)
+ * Get, set, delete or watch keys in etcd key-value store.
+ *
+ * Category: clustering,database
+ * Since: 3.19
+ * Maven coordinates: org.apache.camel:camel-etcd3
+ *
+ * Syntax: <code>etcd3:path</code>
+ *
+ * Path parameter: path
+ * The path the endpoint refers to
+ *
+ * @param path path
+ * @return the dsl builder
+ */
+ default Etcd3EndpointBuilder etcd3(String path) {
+ return Etcd3EndpointBuilderFactory.endpointBuilder("etcd3", path);
+ }
+ /**
+ * Etcd v3 (camel-etcd3)
+ * Get, set, delete or watch keys in etcd key-value store.
+ *
+ * Category: clustering,database
+ * Since: 3.19
+ * Maven coordinates: org.apache.camel:camel-etcd3
+ *
+ * Syntax: <code>etcd3:path</code>
+ *
+ * Path parameter: path
+ * The path the endpoint refers to
+ *
+ * @param componentName to use a custom component name for the endpoint
+ * instead of the default name
+ * @param path path
+ * @return the dsl builder
+ */
+ default Etcd3EndpointBuilder etcd3(String componentName, String path) {
+ return Etcd3EndpointBuilderFactory.endpointBuilder(componentName, path);
+ }
+ }
+
+ /**
+ * The builder of headers' name for the Etcd v3 component.
+ */
+ public static class Etcd3HeaderNameBuilder {
+ /**
+ * The internal instance of the builder used to access to all the
+ * methods representing the name of headers.
+ */
+ private static final Etcd3HeaderNameBuilder INSTANCE = new Etcd3HeaderNameBuilder();
+
+ /**
+ * The action to perform. Supported values: set get delete.
+ *
+ * The option is a: {@code String} type.
+ *
+ * Group: producer
+ *
+ * @return the name of the header {@code EtcdAction}.
+ */
+ public String etcdAction() {
+ return "EtcdAction";
+ }
+
+ /**
+ * The target path.
+ *
+ * The option is a: {@code String} type.
+ *
+ * Group: common
+ *
+ * @return the name of the header {@code EtcdPath}.
+ */
+ public String etcdPath() {
+ return "EtcdPath";
+ }
+
+ /**
+ * To apply an action on all the key-value pairs whose key that starts
+ * with the target path.
+ *
+ * The option is a: {@code Boolean} type.
+ *
+ * Group: producer
+ *
+ * @return the name of the header {@code EtcdIsPrefix}.
+ */
+ public String etcdIsPrefix() {
+ return "EtcdIsPrefix";
+ }
+
+ /**
+ * The charset to use for the keys.
+ *
+ * The option is a: {@code String} type.
+ *
+ * Group: producer
+ *
+ * @return the name of the header {@code EtcdKeyCharset}.
+ */
+ public String etcdKeyCharset() {
+ return "EtcdKeyCharset";
+ }
+
+ /**
+ * The charset to use for the values.
+ *
+ * The option is a: {@code String} type.
+ *
+ * Group: producer
+ *
+ * @return the name of the header {@code EtcdValueCharset}.
+ */
+ public String etcdValueCharset() {
+ return "EtcdValueCharset";
+ }
+ }
+ static Etcd3EndpointBuilder endpointBuilder(
+ String componentName,
+ String path) {
+ class Etcd3EndpointBuilderImpl extends AbstractEndpointBuilder implements Etcd3EndpointBuilder, AdvancedEtcd3EndpointBuilder {
+ public Etcd3EndpointBuilderImpl(String path) {
+ super(componentName, path);
+ }
+ }
+ return new Etcd3EndpointBuilderImpl(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 39e5d475aa6..a39fde7c7f2 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
@@ -106,6 +106,7 @@ org.apache.camel.component.dynamicrouter.DynamicRouterComponent=camel:dynamic-ro
org.apache.camel.component.ehcache.EhcacheComponent=camel:ehcache
org.apache.camel.component.elasticsearch.ElasticsearchComponent=camel:elasticsearch-rest
org.apache.camel.component.es.ElasticsearchComponent=camel:elasticsearch
+org.apache.camel.component.etcd3.Etcd3Component=camel:etcd3
org.apache.camel.component.event.EventComponent=camel:spring
org.apache.camel.component.exec.ExecComponent=camel:exec
org.apache.camel.component.facebook.FacebookComponent=camel:facebook