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 2021/02/23 08:25:50 UTC
[camel] branch master updated (9fd9aa1 -> 3d39afd)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git.
from 9fd9aa1 CAMEL-16115 - Remove Camel-AWS-* components - AWS-IAM
new 0b4ae8b CAMEL-16115 - Remove Camel-AWS-* components - AWS-EKS
new f9ed0c3 CAMEL-16115 - Remove Camel-AWS-* components - AWS-EKS
new 9f8f549 CAMEL-16115 - Remove Camel-AWS-* components - AWS-EKS
new eaf1e83 CAMEL-16115 - Remove Camel-AWS-* components - AWS-EKS
new 3d39afd CAMEL-16115 - Remove Camel-AWS-* components - AWS-EKS
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
bom/camel-bom/pom.xml | 5 -
.../org/apache/camel/catalog/components.properties | 1 -
.../apache/camel/catalog/components/aws-eks.json | 52 ---
.../org/apache/camel/catalog/docs.properties | 1 -
.../camel/catalog/docs/aws-eks-component.adoc | 177 ----------
components/camel-aws-eks/pom.xml | 72 ----
.../component/aws/eks/EKSComponentConfigurer.java | 113 -------
.../component/aws/eks/EKSEndpointConfigurer.java | 97 ------
.../component/aws/eks/EKSEndpointUriFactory.java | 74 ----
.../services/org/apache/camel/component.properties | 7 -
.../services/org/apache/camel/component/aws-eks | 2 -
.../org/apache/camel/configurer/aws-eks-component | 2 -
.../org/apache/camel/configurer/aws-eks-endpoint | 2 -
.../org/apache/camel/urifactory/aws-eks-endpoint | 2 -
.../apache/camel/component/aws/eks/aws-eks.json | 52 ---
.../src/main/docs/aws-eks-component.adoc | 177 ----------
.../camel/component/aws/eks/EKSComponent.java | 81 -----
.../aws/eks/EKSComponentVerifierExtension.java | 92 -----
.../camel/component/aws/eks/EKSConfiguration.java | 165 ---------
.../camel/component/aws/eks/EKSConstants.java | 29 --
.../camel/component/aws/eks/EKSEndpoint.java | 123 -------
.../camel/component/aws/eks/EKSOperations.java | 25 --
.../camel/component/aws/eks/EKSProducer.java | 179 ----------
.../component/aws/eks/AmazonEKSClientMock.java | 77 -----
.../aws/eks/EKSComponentClientRegistryTest.java | 70 ----
.../aws/eks/EKSComponentConfigurationTest.java | 69 ----
.../aws/eks/EKSComponentVerifierExtensionTest.java | 76 -----
.../component/aws/eks/EKSProducerSpringTest.java | 118 -------
.../camel/component/aws/eks/EKSProducerTest.java | 138 --------
.../src/test/resources/log4j2.properties | 28 --
.../aws/eks/EKSComponentSpringTest-context.xml | 50 ---
components/pom.xml | 1 -
core/camel-allcomponents/pom.xml | 4 -
.../component/ComponentsBuilderFactory.java | 16 +-
.../dsl/AwsEksComponentBuilderFactory.java | 292 ----------------
.../src/generated/resources/metadata.json | 23 --
.../builder/endpoint/EndpointBuilderFactory.java | 3 +-
.../camel/builder/endpoint/EndpointBuilders.java | 3 +-
.../builder/endpoint/StaticEndpointBuilders.java | 47 +--
.../endpoint/dsl/EKSEndpointBuilderFactory.java | 376 ---------------------
docs/components/modules/ROOT/nav.adoc | 1 -
.../modules/ROOT/pages/aws-eks-component.adoc | 179 ----------
.../ROOT/pages/camel-3x-upgrade-guide-3_9.adoc | 1 +
parent/pom.xml | 5 -
44 files changed, 5 insertions(+), 3102 deletions(-)
delete mode 100644 catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/aws-eks.json
delete mode 100644 catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws-eks-component.adoc
delete mode 100644 components/camel-aws-eks/pom.xml
delete mode 100644 components/camel-aws-eks/src/generated/java/org/apache/camel/component/aws/eks/EKSComponentConfigurer.java
delete mode 100644 components/camel-aws-eks/src/generated/java/org/apache/camel/component/aws/eks/EKSEndpointConfigurer.java
delete mode 100644 components/camel-aws-eks/src/generated/java/org/apache/camel/component/aws/eks/EKSEndpointUriFactory.java
delete mode 100644 components/camel-aws-eks/src/generated/resources/META-INF/services/org/apache/camel/component.properties
delete mode 100644 components/camel-aws-eks/src/generated/resources/META-INF/services/org/apache/camel/component/aws-eks
delete mode 100644 components/camel-aws-eks/src/generated/resources/META-INF/services/org/apache/camel/configurer/aws-eks-component
delete mode 100644 components/camel-aws-eks/src/generated/resources/META-INF/services/org/apache/camel/configurer/aws-eks-endpoint
delete mode 100644 components/camel-aws-eks/src/generated/resources/META-INF/services/org/apache/camel/urifactory/aws-eks-endpoint
delete mode 100644 components/camel-aws-eks/src/generated/resources/org/apache/camel/component/aws/eks/aws-eks.json
delete mode 100644 components/camel-aws-eks/src/main/docs/aws-eks-component.adoc
delete mode 100644 components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSComponent.java
delete mode 100644 components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSComponentVerifierExtension.java
delete mode 100644 components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSConfiguration.java
delete mode 100644 components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSConstants.java
delete mode 100644 components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSEndpoint.java
delete mode 100644 components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSOperations.java
delete mode 100644 components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSProducer.java
delete mode 100644 components/camel-aws-eks/src/test/java/org/apache/camel/component/aws/eks/AmazonEKSClientMock.java
delete mode 100644 components/camel-aws-eks/src/test/java/org/apache/camel/component/aws/eks/EKSComponentClientRegistryTest.java
delete mode 100644 components/camel-aws-eks/src/test/java/org/apache/camel/component/aws/eks/EKSComponentConfigurationTest.java
delete mode 100644 components/camel-aws-eks/src/test/java/org/apache/camel/component/aws/eks/EKSComponentVerifierExtensionTest.java
delete mode 100644 components/camel-aws-eks/src/test/java/org/apache/camel/component/aws/eks/EKSProducerSpringTest.java
delete mode 100644 components/camel-aws-eks/src/test/java/org/apache/camel/component/aws/eks/EKSProducerTest.java
delete mode 100644 components/camel-aws-eks/src/test/resources/log4j2.properties
delete mode 100644 components/camel-aws-eks/src/test/resources/org/apache/camel/component/aws/eks/EKSComponentSpringTest-context.xml
delete mode 100644 core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsEksComponentBuilderFactory.java
delete mode 100644 core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/EKSEndpointBuilderFactory.java
delete mode 100644 docs/components/modules/ROOT/pages/aws-eks-component.adoc
[camel] 04/05: CAMEL-16115 - Remove Camel-AWS-* components - AWS-EKS
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit eaf1e83b8dfc85a647e90e72fb91c185be6b59b6
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Feb 23 08:35:32 2021 +0100
CAMEL-16115 - Remove Camel-AWS-* components - AWS-EKS
---
.../org/apache/camel/catalog/components.properties | 1 -
.../apache/camel/catalog/components/aws-eks.json | 52 ------
.../org/apache/camel/catalog/docs.properties | 1 -
.../camel/catalog/docs/aws-eks-component.adoc | 177 --------------------
.../src/generated/resources/metadata.json | 23 ---
.../builder/endpoint/EndpointBuilderFactory.java | 3 +-
.../camel/builder/endpoint/EndpointBuilders.java | 3 +-
docs/components/modules/ROOT/nav.adoc | 1 -
.../modules/ROOT/pages/aws-eks-component.adoc | 179 ---------------------
9 files changed, 2 insertions(+), 438 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 51d6ba7..b4c2ee4 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
@@ -23,7 +23,6 @@ aws-ddb
aws-ddbstream
aws-ec2
aws-ecs
-aws-eks
aws-s3
aws-swf
aws2-athena
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/aws-eks.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/aws-eks.json
deleted file mode 100644
index 76bef36..0000000
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/aws-eks.json
+++ /dev/null
@@ -1,52 +0,0 @@
-{
- "component": {
- "kind": "component",
- "name": "aws-eks",
- "title": "AWS Elastic Kubernetes Service (EKS)",
- "description": "Manage AWS EKS cluster instances.",
- "deprecated": true,
- "deprecatedSince": "3.8.0",
- "firstVersion": "3.0.0",
- "label": "cloud,management",
- "javaType": "org.apache.camel.component.aws.eks.EKSComponent",
- "supportLevel": "Stable",
- "groupId": "org.apache.camel",
- "artifactId": "camel-aws-eks",
- "version": "3.9.0-SNAPSHOT",
- "scheme": "aws-eks",
- "extendsScheme": "",
- "syntax": "aws-eks:label",
- "async": false,
- "api": false,
- "consumerOnly": false,
- "producerOnly": true,
- "lenientProperties": false
- },
- "componentProperties": {
- "autoDiscoverClient": { "kind": "property", "displayName": "Auto Discover Client", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instan [...]
- "accessKey": { "kind": "property", "displayName": "Access Key", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "Amazon AWS Access Key" },
- "configuration": { "kind": "property", "displayName": "Configuration", "group": "producer", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.aws.eks.EKSConfiguration", "deprecated": false, "autowired": false, "secret": false, "description": "The component configuration" },
- "eksClient": { "kind": "property", "displayName": "Eks Client", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "com.amazonaws.services.eks.AmazonEKS", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "To use a existing configured AWS EKS as client" },
- "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 [...]
- "operation": { "kind": "property", "displayName": "Operation", "group": "producer", "label": "producer", "required": true, "type": "object", "javaType": "org.apache.camel.component.aws.eks.EKSOperations", "enum": [ "listClusters", "describeCluster", "createCluster", "deleteCluster" ], "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "desc [...]
- "proxyHost": { "kind": "property", "displayName": "Proxy Host", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "To define a proxy host when instantiating the EKS client" },
- "proxyPort": { "kind": "property", "displayName": "Proxy Port", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "To define a proxy port when instantiating the EKS client" },
- "proxyProtocol": { "kind": "property", "displayName": "Proxy Protocol", "group": "producer", "label": "", "required": false, "type": "object", "javaType": "com.amazonaws.Protocol", "enum": [ "HTTP", "HTTPS" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "HTTPS", "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "To define a proxy protocol when instantiating the EKS client" },
- "region": { "kind": "property", "displayName": "Region", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "The region in which EKS client needs to work. When using this parameter, the configuration will expect the capitalized name of the region [...]
- "secretKey": { "kind": "property", "displayName": "Secret Key", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "Amazon AWS Secret Key" },
- "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 [...]
- },
- "properties": {
- "label": { "kind": "path", "displayName": "Label", "group": "producer", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "Logical name" },
- "autoDiscoverClient": { "kind": "parameter", "displayName": "Auto Discover Client", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client insta [...]
- "accessKey": { "kind": "parameter", "displayName": "Access Key", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "Amazon AWS Access Key" },
- "eksClient": { "kind": "parameter", "displayName": "Eks Client", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "com.amazonaws.services.eks.AmazonEKS", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "To use a existing configured AWS EKS as client" },
- "lazyStartProducer": { "kind": "parameter", "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 sta [...]
- "operation": { "kind": "parameter", "displayName": "Operation", "group": "producer", "label": "producer", "required": true, "type": "object", "javaType": "org.apache.camel.component.aws.eks.EKSOperations", "enum": [ "listClusters", "describeCluster", "createCluster", "deleteCluster" ], "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "des [...]
- "proxyHost": { "kind": "parameter", "displayName": "Proxy Host", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "To define a proxy host when instantiating the EKS client" },
- "proxyPort": { "kind": "parameter", "displayName": "Proxy Port", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "To define a proxy port when instantiating the EKS client" },
- "proxyProtocol": { "kind": "parameter", "displayName": "Proxy Protocol", "group": "producer", "label": "", "required": false, "type": "object", "javaType": "com.amazonaws.Protocol", "enum": [ "HTTP", "HTTPS" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "HTTPS", "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "To define a proxy protocol when instantiating the EKS client" },
- "region": { "kind": "parameter", "displayName": "Region", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "The region in which EKS client needs to work. When using this parameter, the configuration will expect the capitalized name of the region [...]
- "secretKey": { "kind": "parameter", "displayName": "Secret Key", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "Amazon AWS Secret Key" }
- }
-}
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs.properties b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs.properties
index d245711..52bf99b 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs.properties
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs.properties
@@ -27,7 +27,6 @@ aws-ddb-component
aws-ddbstream-component
aws-ec2-component
aws-ecs-component
-aws-eks-component
aws-s3-component
aws-summary
aws-swf-component
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws-eks-component.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws-eks-component.adoc
deleted file mode 100644
index 0572448..0000000
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws-eks-component.adoc
+++ /dev/null
@@ -1,177 +0,0 @@
-[[aws-eks-component]]
-= AWS Elastic Kubernetes Service (EKS) Component (deprecated)
-:docTitle: AWS Elastic Kubernetes Service (EKS)
-:artifactId: camel-aws-eks
-:description: Manage AWS EKS cluster instances.
-:since: 3.0
-:supportLevel: Stable-deprecated
-:deprecated: *deprecated*
-:component-header: Only producer is supported
-include::{cq-version}@camel-quarkus:ROOT:partial$reference/components/aws-eks.adoc[opts=optional]
-//Manually maintained attributes
-:group: AWS
-
-*Since Camel {since}*
-
-*{component-header}*
-
-The EKS component supports create, delete, describe and list
-https://aws.amazon.com/eks/[AWS EKS] clusters instances.
-
-Prerequisites
-
-You must have a valid Amazon Web Services developer account, and be
-signed up to use Amazon EKS. More information is available at
-https://aws.amazon.com/eks/[Amazon EKS].
-
-== URI Format
-
-[source,java]
--------------------------
-aws-eks://label[?options]
--------------------------
-
-You can append query options to the URI in the following format,
-?options=value&option2=value&...
-
-== URI Options
-
-
-// component options: START
-The AWS Elastic Kubernetes Service (EKS) component supports 12 options, which are listed below.
-
-
-
-[width="100%",cols="2,5,^1,2",options="header"]
-|===
-| Name | Description | Default | Type
-| *autoDiscoverClient* (common) | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | boolean
-| *accessKey* (producer) | Amazon AWS Access Key | | String
-| *configuration* (producer) | The component configuration | | EKSConfiguration
-| *eksClient* (producer) | To use a existing configured AWS EKS as client | | AmazonEKS
-| *lazyStartProducer* (producer) | 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 [...]
-| *operation* (producer) | *Required* The operation to perform. There are 4 enums and the value can be one of: listClusters, describeCluster, createCluster, deleteCluster | | EKSOperations
-| *proxyHost* (producer) | To define a proxy host when instantiating the EKS client | | String
-| *proxyPort* (producer) | To define a proxy port when instantiating the EKS client | | Integer
-| *proxyProtocol* (producer) | To define a proxy protocol when instantiating the EKS client. There are 2 enums and the value can be one of: HTTP, HTTPS | HTTPS | Protocol
-| *region* (producer) | The region in which EKS client needs to work. When using this parameter, the configuration will expect the capitalized name of the region (for example AP_EAST_1) You'll need to use the name Regions.EU_WEST_1.name() | | String
-| *secretKey* (producer) | Amazon AWS Secret Key | | String
-| *autowiredEnabled* (advanced) | 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. | true | boolean
-|===
-// component options: END
-
-
-
-
-// endpoint options: START
-The AWS Elastic Kubernetes Service (EKS) endpoint is configured using URI syntax:
-
-----
-aws-eks:label
-----
-
-with the following path and query parameters:
-
-=== Path Parameters (1 parameters):
-
-
-[width="100%",cols="2,5,^1,2",options="header"]
-|===
-| Name | Description | Default | Type
-| *label* | *Required* Logical name | | String
-|===
-
-
-=== Query Parameters (10 parameters):
-
-
-[width="100%",cols="2,5,^1,2",options="header"]
-|===
-| Name | Description | Default | Type
-| *autoDiscoverClient* (common) | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | boolean
-| *accessKey* (producer) | Amazon AWS Access Key | | String
-| *eksClient* (producer) | To use a existing configured AWS EKS as client | | AmazonEKS
-| *lazyStartProducer* (producer) | 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 [...]
-| *operation* (producer) | *Required* The operation to perform. There are 4 enums and the value can be one of: listClusters, describeCluster, createCluster, deleteCluster | | EKSOperations
-| *proxyHost* (producer) | To define a proxy host when instantiating the EKS client | | String
-| *proxyPort* (producer) | To define a proxy port when instantiating the EKS client | | Integer
-| *proxyProtocol* (producer) | To define a proxy protocol when instantiating the EKS client. There are 2 enums and the value can be one of: HTTP, HTTPS | HTTPS | Protocol
-| *region* (producer) | The region in which EKS client needs to work. When using this parameter, the configuration will expect the capitalized name of the region (for example AP_EAST_1) You'll need to use the name Regions.EU_WEST_1.name() | | String
-| *secretKey* (producer) | Amazon AWS Secret Key | | String
-|===
-// endpoint options: END
-
-
-
-
-Required EKS component options
-
-You have to provide the amazonEKSClient in the
-Registry or your accessKey and secretKey to access
-the https://aws.amazon.com/eks/[Amazon EKS] service.
-
-== Usage
-
-=== Message headers evaluated by the EKS producer
-
-[width="100%",cols="10%,10%,80%",options="header",]
-|=======================================================================
-|Header |Type |Description
-
-|`CamelAwsEKSMaxResults` |`Integer` |The limit number of results while listing clusters
-
-|`CamelAwsEKSOperation` |`String` |The operation we want to perform
-
-|`CamelAwsEKSDescription` |`String` |A key description to use while performing a createKey operation
-
-|`CamelAwsEKSClusterName` |`String` |The cluster name
-
-|`CamelAwsEKSRoleARN` |`String` |The role ARN to use while creating the cluster
-
-|`CamelAwsEKSVPCConfig` |`VPCConfigRequest` |The VPC config for the creations of an EKS cluster
-|=======================================================================
-
-=== EKS Producer operations
-
-Camel-AWS EKS component provides the following operation on the producer side:
-
-- listClusters
-- createCluster
-- describeCluster
-- deleteCluster
-
-== Producer Examples
-
-- listClusters: this operation will list the available clusters in EKS
-
-[source,java]
---------------------------------------------------------------------------------
-from("direct:listClusters")
- .to("aws-eks://test?ecsClient=#amazonEksClient&operation=listClusters")
---------------------------------------------------------------------------------
-
-== Automatic detection of AmazonEKS client in registry
-
-The component is capable of detecting the presence of an AmazonEKS bean into the registry.
-If it's the only instance of that type it will be used as client and you won't have to define it as uri parameter.
-This may be really useful for smarter configuration of the endpoint.
-
-Dependencies
-
-Maven users will need to add the following dependency to their pom.xml.
-
-*pom.xml*
-
-[source,xml]
----------------------------------------
-<dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-aws-eks</artifactId>
- <version>${camel-version}</version>
-</dependency>
----------------------------------------
-
-where `$\{camel-version}` must be replaced by the actual version of Camel.
-
-
-include::camel-spring-boot::page$aws-eks-starter.adoc[]
diff --git a/core/camel-componentdsl/src/generated/resources/metadata.json b/core/camel-componentdsl/src/generated/resources/metadata.json
index ef3fba2..a8f505e 100644
--- a/core/camel-componentdsl/src/generated/resources/metadata.json
+++ b/core/camel-componentdsl/src/generated/resources/metadata.json
@@ -1021,29 +1021,6 @@
"producerOnly": true,
"lenientProperties": false
},
- "AwsEksComponentBuilderFactory": {
- "kind": "component",
- "name": "aws-eks",
- "title": "AWS Elastic Kubernetes Service (EKS)",
- "description": "Manage AWS EKS cluster instances.",
- "deprecated": true,
- "deprecatedSince": "3.8.0",
- "firstVersion": "3.0.0",
- "label": "cloud,management",
- "javaType": "org.apache.camel.component.aws.eks.EKSComponent",
- "supportLevel": "Stable",
- "groupId": "org.apache.camel",
- "artifactId": "camel-aws-eks",
- "version": "3.9.0-SNAPSHOT",
- "scheme": "aws-eks",
- "extendsScheme": "",
- "syntax": "aws-eks:label",
- "async": false,
- "api": false,
- "consumerOnly": false,
- "producerOnly": true,
- "lenientProperties": false
- },
"AwsS3ComponentBuilderFactory": {
"kind": "component",
"name": "aws-s3",
diff --git a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
index d7981ac..d66e422 100644
--- a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
@@ -109,7 +109,6 @@ public interface EndpointBuilderFactory
org.apache.camel.builder.endpoint.dsl.ECS2EndpointBuilderFactory.ECS2Builders,
org.apache.camel.builder.endpoint.dsl.ECSEndpointBuilderFactory.ECSBuilders,
org.apache.camel.builder.endpoint.dsl.EKS2EndpointBuilderFactory.EKS2Builders,
- org.apache.camel.builder.endpoint.dsl.EKSEndpointBuilderFactory.EKSBuilders,
org.apache.camel.builder.endpoint.dsl.EhcacheEndpointBuilderFactory.EhcacheBuilders,
org.apache.camel.builder.endpoint.dsl.ElasticsearchEndpointBuilderFactory.ElasticsearchBuilders,
org.apache.camel.builder.endpoint.dsl.ElsqlEndpointBuilderFactory.ElsqlBuilders,
@@ -384,4 +383,4 @@ public interface EndpointBuilderFactory
};
}
}
-//CHECKSTYLE:ON
\ No newline at end of file
+//CHECKSTYLE:ON
diff --git a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
index 9f05477..0ba239b 100644
--- a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
+++ b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
@@ -106,7 +106,6 @@ public interface EndpointBuilders
org.apache.camel.builder.endpoint.dsl.ECS2EndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.ECSEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.EKS2EndpointBuilderFactory,
- org.apache.camel.builder.endpoint.dsl.EKSEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.EhcacheEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.ElasticsearchEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.ElsqlEndpointBuilderFactory,
@@ -368,4 +367,4 @@ public interface EndpointBuilders
org.apache.camel.builder.endpoint.dsl.ZooKeeperMasterEndpointBuilderFactory {
}
-//CHECKSTYLE:ON
\ No newline at end of file
+//CHECKSTYLE:ON
diff --git a/docs/components/modules/ROOT/nav.adoc b/docs/components/modules/ROOT/nav.adoc
index 0bf1578e..dc7cbad 100644
--- a/docs/components/modules/ROOT/nav.adoc
+++ b/docs/components/modules/ROOT/nav.adoc
@@ -27,7 +27,6 @@
*** xref:aws-ddbstream-component.adoc[AWS DynamoDB Streams]
*** xref:aws-ec2-component.adoc[AWS Elastic Compute Cloud (EC2)]
*** xref:aws-ecs-component.adoc[AWS Elastic Container Service (ECS)]
-*** xref:aws-eks-component.adoc[AWS Elastic Kubernetes Service (EKS)]
*** xref:aws-s3-component.adoc[AWS S3 Storage Service]
*** xref:aws-swf-component.adoc[AWS Simple Workflow (SWF)]
** xref:aws2-summary.adoc[AWS 2]
diff --git a/docs/components/modules/ROOT/pages/aws-eks-component.adoc b/docs/components/modules/ROOT/pages/aws-eks-component.adoc
deleted file mode 100644
index 7851732..0000000
--- a/docs/components/modules/ROOT/pages/aws-eks-component.adoc
+++ /dev/null
@@ -1,179 +0,0 @@
-[[aws-eks-component]]
-= AWS Elastic Kubernetes Service (EKS) Component (deprecated)
-//THIS FILE IS COPIED: EDIT THE SOURCE FILE:
-:page-source: components/camel-aws-eks/src/main/docs/aws-eks-component.adoc
-:docTitle: AWS Elastic Kubernetes Service (EKS)
-:artifactId: camel-aws-eks
-:description: Manage AWS EKS cluster instances.
-:since: 3.0
-:supportLevel: Stable-deprecated
-:deprecated: *deprecated*
-:component-header: Only producer is supported
-include::{cq-version}@camel-quarkus:ROOT:partial$reference/components/aws-eks.adoc[opts=optional]
-//Manually maintained attributes
-:group: AWS
-
-*Since Camel {since}*
-
-*{component-header}*
-
-The EKS component supports create, delete, describe and list
-https://aws.amazon.com/eks/[AWS EKS] clusters instances.
-
-Prerequisites
-
-You must have a valid Amazon Web Services developer account, and be
-signed up to use Amazon EKS. More information is available at
-https://aws.amazon.com/eks/[Amazon EKS].
-
-== URI Format
-
-[source,java]
--------------------------
-aws-eks://label[?options]
--------------------------
-
-You can append query options to the URI in the following format,
-?options=value&option2=value&...
-
-== URI Options
-
-
-// component options: START
-The AWS Elastic Kubernetes Service (EKS) component supports 12 options, which are listed below.
-
-
-
-[width="100%",cols="2,5,^1,2",options="header"]
-|===
-| Name | Description | Default | Type
-| *autoDiscoverClient* (common) | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | boolean
-| *accessKey* (producer) | Amazon AWS Access Key | | String
-| *configuration* (producer) | The component configuration | | EKSConfiguration
-| *eksClient* (producer) | To use a existing configured AWS EKS as client | | AmazonEKS
-| *lazyStartProducer* (producer) | 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 [...]
-| *operation* (producer) | *Required* The operation to perform. There are 4 enums and the value can be one of: listClusters, describeCluster, createCluster, deleteCluster | | EKSOperations
-| *proxyHost* (producer) | To define a proxy host when instantiating the EKS client | | String
-| *proxyPort* (producer) | To define a proxy port when instantiating the EKS client | | Integer
-| *proxyProtocol* (producer) | To define a proxy protocol when instantiating the EKS client. There are 2 enums and the value can be one of: HTTP, HTTPS | HTTPS | Protocol
-| *region* (producer) | The region in which EKS client needs to work. When using this parameter, the configuration will expect the capitalized name of the region (for example AP_EAST_1) You'll need to use the name Regions.EU_WEST_1.name() | | String
-| *secretKey* (producer) | Amazon AWS Secret Key | | String
-| *autowiredEnabled* (advanced) | 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. | true | boolean
-|===
-// component options: END
-
-
-
-
-// endpoint options: START
-The AWS Elastic Kubernetes Service (EKS) endpoint is configured using URI syntax:
-
-----
-aws-eks:label
-----
-
-with the following path and query parameters:
-
-=== Path Parameters (1 parameters):
-
-
-[width="100%",cols="2,5,^1,2",options="header"]
-|===
-| Name | Description | Default | Type
-| *label* | *Required* Logical name | | String
-|===
-
-
-=== Query Parameters (10 parameters):
-
-
-[width="100%",cols="2,5,^1,2",options="header"]
-|===
-| Name | Description | Default | Type
-| *autoDiscoverClient* (common) | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | boolean
-| *accessKey* (producer) | Amazon AWS Access Key | | String
-| *eksClient* (producer) | To use a existing configured AWS EKS as client | | AmazonEKS
-| *lazyStartProducer* (producer) | 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 [...]
-| *operation* (producer) | *Required* The operation to perform. There are 4 enums and the value can be one of: listClusters, describeCluster, createCluster, deleteCluster | | EKSOperations
-| *proxyHost* (producer) | To define a proxy host when instantiating the EKS client | | String
-| *proxyPort* (producer) | To define a proxy port when instantiating the EKS client | | Integer
-| *proxyProtocol* (producer) | To define a proxy protocol when instantiating the EKS client. There are 2 enums and the value can be one of: HTTP, HTTPS | HTTPS | Protocol
-| *region* (producer) | The region in which EKS client needs to work. When using this parameter, the configuration will expect the capitalized name of the region (for example AP_EAST_1) You'll need to use the name Regions.EU_WEST_1.name() | | String
-| *secretKey* (producer) | Amazon AWS Secret Key | | String
-|===
-// endpoint options: END
-
-
-
-
-Required EKS component options
-
-You have to provide the amazonEKSClient in the
-Registry or your accessKey and secretKey to access
-the https://aws.amazon.com/eks/[Amazon EKS] service.
-
-== Usage
-
-=== Message headers evaluated by the EKS producer
-
-[width="100%",cols="10%,10%,80%",options="header",]
-|=======================================================================
-|Header |Type |Description
-
-|`CamelAwsEKSMaxResults` |`Integer` |The limit number of results while listing clusters
-
-|`CamelAwsEKSOperation` |`String` |The operation we want to perform
-
-|`CamelAwsEKSDescription` |`String` |A key description to use while performing a createKey operation
-
-|`CamelAwsEKSClusterName` |`String` |The cluster name
-
-|`CamelAwsEKSRoleARN` |`String` |The role ARN to use while creating the cluster
-
-|`CamelAwsEKSVPCConfig` |`VPCConfigRequest` |The VPC config for the creations of an EKS cluster
-|=======================================================================
-
-=== EKS Producer operations
-
-Camel-AWS EKS component provides the following operation on the producer side:
-
-- listClusters
-- createCluster
-- describeCluster
-- deleteCluster
-
-== Producer Examples
-
-- listClusters: this operation will list the available clusters in EKS
-
-[source,java]
---------------------------------------------------------------------------------
-from("direct:listClusters")
- .to("aws-eks://test?ecsClient=#amazonEksClient&operation=listClusters")
---------------------------------------------------------------------------------
-
-== Automatic detection of AmazonEKS client in registry
-
-The component is capable of detecting the presence of an AmazonEKS bean into the registry.
-If it's the only instance of that type it will be used as client and you won't have to define it as uri parameter.
-This may be really useful for smarter configuration of the endpoint.
-
-Dependencies
-
-Maven users will need to add the following dependency to their pom.xml.
-
-*pom.xml*
-
-[source,xml]
----------------------------------------
-<dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-aws-eks</artifactId>
- <version>${camel-version}</version>
-</dependency>
----------------------------------------
-
-where `$\{camel-version}` must be replaced by the actual version of Camel.
-
-
-include::camel-spring-boot::page$aws-eks-starter.adoc[]
[camel] 01/05: CAMEL-16115 - Remove Camel-AWS-* components - AWS-EKS
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 0b4ae8b6f970308b26f6ed94a0987ce33846ef60
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Feb 23 08:27:51 2021 +0100
CAMEL-16115 - Remove Camel-AWS-* components - AWS-EKS
---
components/camel-aws-eks/pom.xml | 72 ---------
.../component/aws/eks/EKSComponentConfigurer.java | 113 -------------
.../component/aws/eks/EKSEndpointConfigurer.java | 97 -----------
.../component/aws/eks/EKSEndpointUriFactory.java | 74 ---------
.../services/org/apache/camel/component.properties | 7 -
.../services/org/apache/camel/component/aws-eks | 2 -
.../org/apache/camel/configurer/aws-eks-component | 2 -
.../org/apache/camel/configurer/aws-eks-endpoint | 2 -
.../org/apache/camel/urifactory/aws-eks-endpoint | 2 -
.../apache/camel/component/aws/eks/aws-eks.json | 52 ------
.../src/main/docs/aws-eks-component.adoc | 177 --------------------
.../camel/component/aws/eks/EKSComponent.java | 81 ----------
.../aws/eks/EKSComponentVerifierExtension.java | 92 -----------
.../camel/component/aws/eks/EKSConfiguration.java | 165 -------------------
.../camel/component/aws/eks/EKSConstants.java | 29 ----
.../camel/component/aws/eks/EKSEndpoint.java | 123 --------------
.../camel/component/aws/eks/EKSOperations.java | 25 ---
.../camel/component/aws/eks/EKSProducer.java | 179 ---------------------
.../component/aws/eks/AmazonEKSClientMock.java | 77 ---------
.../aws/eks/EKSComponentClientRegistryTest.java | 70 --------
.../aws/eks/EKSComponentConfigurationTest.java | 69 --------
.../aws/eks/EKSComponentVerifierExtensionTest.java | 76 ---------
.../component/aws/eks/EKSProducerSpringTest.java | 118 --------------
.../camel/component/aws/eks/EKSProducerTest.java | 138 ----------------
.../src/test/resources/log4j2.properties | 28 ----
.../aws/eks/EKSComponentSpringTest-context.xml | 50 ------
components/pom.xml | 1 -
27 files changed, 1921 deletions(-)
diff --git a/components/camel-aws-eks/pom.xml b/components/camel-aws-eks/pom.xml
deleted file mode 100644
index 073f627..0000000
--- a/components/camel-aws-eks/pom.xml
+++ /dev/null
@@ -1,72 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
-
- Licensed to the Apache Software Foundation (ASF) under one or more
- contributor license agreements. See the NOTICE file distributed with
- this work for additional information regarding copyright ownership.
- The ASF licenses this file to You under the Apache License, Version 2.0
- (the "License"); you may not use this file except in compliance with
- the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
-
--->
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
- <modelVersion>4.0.0</modelVersion>
-
- <parent>
- <groupId>org.apache.camel</groupId>
- <artifactId>components</artifactId>
- <version>3.9.0-SNAPSHOT</version>
- </parent>
-
- <artifactId>camel-aws-eks</artifactId>
- <packaging>jar</packaging>
-
- <name>Camel :: AWS EKS (deprecated)</name>
- <description>A Camel Amazon EKS Web Service Component</description>
-
- <properties>
- <deprecatedSince>3.8.0</deprecatedSince>
- </properties>
-
- <dependencies>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-support</artifactId>
- </dependency>
- <dependency>
- <groupId>com.amazonaws</groupId>
- <artifactId>aws-java-sdk-eks</artifactId>
- <version>${aws-java-sdk-version}</version>
- </dependency>
-
- <!-- for testing -->
- <dependency>
- <groupId>org.junit.jupiter</groupId>
- <artifactId>junit-jupiter</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-test-spring-junit5</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-core-catalog</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.apache.logging.log4j</groupId>
- <artifactId>log4j-slf4j-impl</artifactId>
- <scope>test</scope>
- </dependency>
- </dependencies>
-</project>
diff --git a/components/camel-aws-eks/src/generated/java/org/apache/camel/component/aws/eks/EKSComponentConfigurer.java b/components/camel-aws-eks/src/generated/java/org/apache/camel/component/aws/eks/EKSComponentConfigurer.java
deleted file mode 100644
index 0429da6..0000000
--- a/components/camel-aws-eks/src/generated/java/org/apache/camel/component/aws/eks/EKSComponentConfigurer.java
+++ /dev/null
@@ -1,113 +0,0 @@
-/* Generated by camel build tools - do NOT edit this file! */
-package org.apache.camel.component.aws.eks;
-
-import java.util.Map;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.spi.ExtendedPropertyConfigurerGetter;
-import org.apache.camel.spi.PropertyConfigurerGetter;
-import org.apache.camel.spi.ConfigurerStrategy;
-import org.apache.camel.spi.GeneratedPropertyConfigurer;
-import org.apache.camel.util.CaseInsensitiveMap;
-import org.apache.camel.support.component.PropertyConfigurerSupport;
-
-/**
- * Generated by camel build tools - do NOT edit this file!
- */
-@SuppressWarnings("unchecked")
-public class EKSComponentConfigurer extends PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
-
- private org.apache.camel.component.aws.eks.EKSConfiguration getOrCreateConfiguration(EKSComponent target) {
- if (target.getConfiguration() == null) {
- target.setConfiguration(new org.apache.camel.component.aws.eks.EKSConfiguration());
- }
- return target.getConfiguration();
- }
-
- @Override
- public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
- EKSComponent target = (EKSComponent) obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "accesskey":
- case "accessKey": getOrCreateConfiguration(target).setAccessKey(property(camelContext, java.lang.String.class, value)); return true;
- case "autodiscoverclient":
- case "autoDiscoverClient": getOrCreateConfiguration(target).setAutoDiscoverClient(property(camelContext, boolean.class, value)); return true;
- case "autowiredenabled":
- case "autowiredEnabled": target.setAutowiredEnabled(property(camelContext, boolean.class, value)); return true;
- case "configuration": target.setConfiguration(property(camelContext, org.apache.camel.component.aws.eks.EKSConfiguration.class, value)); return true;
- case "eksclient":
- case "eksClient": getOrCreateConfiguration(target).setEksClient(property(camelContext, com.amazonaws.services.eks.AmazonEKS.class, value)); return true;
- case "lazystartproducer":
- case "lazyStartProducer": target.setLazyStartProducer(property(camelContext, boolean.class, value)); return true;
- case "operation": getOrCreateConfiguration(target).setOperation(property(camelContext, org.apache.camel.component.aws.eks.EKSOperations.class, value)); return true;
- case "proxyhost":
- case "proxyHost": getOrCreateConfiguration(target).setProxyHost(property(camelContext, java.lang.String.class, value)); return true;
- case "proxyport":
- case "proxyPort": getOrCreateConfiguration(target).setProxyPort(property(camelContext, java.lang.Integer.class, value)); return true;
- case "proxyprotocol":
- case "proxyProtocol": getOrCreateConfiguration(target).setProxyProtocol(property(camelContext, com.amazonaws.Protocol.class, value)); return true;
- case "region": getOrCreateConfiguration(target).setRegion(property(camelContext, java.lang.String.class, value)); return true;
- case "secretkey":
- case "secretKey": getOrCreateConfiguration(target).setSecretKey(property(camelContext, java.lang.String.class, value)); return true;
- default: return false;
- }
- }
-
- @Override
- public Class<?> getOptionType(String name, boolean ignoreCase) {
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "accesskey":
- case "accessKey": return java.lang.String.class;
- case "autodiscoverclient":
- case "autoDiscoverClient": return boolean.class;
- case "autowiredenabled":
- case "autowiredEnabled": return boolean.class;
- case "configuration": return org.apache.camel.component.aws.eks.EKSConfiguration.class;
- case "eksclient":
- case "eksClient": return com.amazonaws.services.eks.AmazonEKS.class;
- case "lazystartproducer":
- case "lazyStartProducer": return boolean.class;
- case "operation": return org.apache.camel.component.aws.eks.EKSOperations.class;
- case "proxyhost":
- case "proxyHost": return java.lang.String.class;
- case "proxyport":
- case "proxyPort": return java.lang.Integer.class;
- case "proxyprotocol":
- case "proxyProtocol": return com.amazonaws.Protocol.class;
- case "region": return java.lang.String.class;
- case "secretkey":
- case "secretKey": return java.lang.String.class;
- default: return null;
- }
- }
-
- @Override
- public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
- EKSComponent target = (EKSComponent) obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "accesskey":
- case "accessKey": return getOrCreateConfiguration(target).getAccessKey();
- case "autodiscoverclient":
- case "autoDiscoverClient": return getOrCreateConfiguration(target).isAutoDiscoverClient();
- case "autowiredenabled":
- case "autowiredEnabled": return target.isAutowiredEnabled();
- case "configuration": return target.getConfiguration();
- case "eksclient":
- case "eksClient": return getOrCreateConfiguration(target).getEksClient();
- case "lazystartproducer":
- case "lazyStartProducer": return target.isLazyStartProducer();
- case "operation": return getOrCreateConfiguration(target).getOperation();
- case "proxyhost":
- case "proxyHost": return getOrCreateConfiguration(target).getProxyHost();
- case "proxyport":
- case "proxyPort": return getOrCreateConfiguration(target).getProxyPort();
- case "proxyprotocol":
- case "proxyProtocol": return getOrCreateConfiguration(target).getProxyProtocol();
- case "region": return getOrCreateConfiguration(target).getRegion();
- case "secretkey":
- case "secretKey": return getOrCreateConfiguration(target).getSecretKey();
- default: return null;
- }
- }
-}
-
diff --git a/components/camel-aws-eks/src/generated/java/org/apache/camel/component/aws/eks/EKSEndpointConfigurer.java b/components/camel-aws-eks/src/generated/java/org/apache/camel/component/aws/eks/EKSEndpointConfigurer.java
deleted file mode 100644
index 46e27df..0000000
--- a/components/camel-aws-eks/src/generated/java/org/apache/camel/component/aws/eks/EKSEndpointConfigurer.java
+++ /dev/null
@@ -1,97 +0,0 @@
-/* Generated by camel build tools - do NOT edit this file! */
-package org.apache.camel.component.aws.eks;
-
-import java.util.Map;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.spi.ExtendedPropertyConfigurerGetter;
-import org.apache.camel.spi.PropertyConfigurerGetter;
-import org.apache.camel.spi.ConfigurerStrategy;
-import org.apache.camel.spi.GeneratedPropertyConfigurer;
-import org.apache.camel.util.CaseInsensitiveMap;
-import org.apache.camel.support.component.PropertyConfigurerSupport;
-
-/**
- * Generated by camel build tools - do NOT edit this file!
- */
-@SuppressWarnings("unchecked")
-public class EKSEndpointConfigurer extends PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
-
- @Override
- public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
- EKSEndpoint target = (EKSEndpoint) obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "accesskey":
- case "accessKey": target.getConfiguration().setAccessKey(property(camelContext, java.lang.String.class, value)); return true;
- case "autodiscoverclient":
- case "autoDiscoverClient": target.getConfiguration().setAutoDiscoverClient(property(camelContext, boolean.class, value)); return true;
- case "eksclient":
- case "eksClient": target.getConfiguration().setEksClient(property(camelContext, com.amazonaws.services.eks.AmazonEKS.class, value)); return true;
- case "lazystartproducer":
- case "lazyStartProducer": target.setLazyStartProducer(property(camelContext, boolean.class, value)); return true;
- case "operation": target.getConfiguration().setOperation(property(camelContext, org.apache.camel.component.aws.eks.EKSOperations.class, value)); return true;
- case "proxyhost":
- case "proxyHost": target.getConfiguration().setProxyHost(property(camelContext, java.lang.String.class, value)); return true;
- case "proxyport":
- case "proxyPort": target.getConfiguration().setProxyPort(property(camelContext, java.lang.Integer.class, value)); return true;
- case "proxyprotocol":
- case "proxyProtocol": target.getConfiguration().setProxyProtocol(property(camelContext, com.amazonaws.Protocol.class, value)); return true;
- case "region": target.getConfiguration().setRegion(property(camelContext, java.lang.String.class, value)); return true;
- case "secretkey":
- case "secretKey": target.getConfiguration().setSecretKey(property(camelContext, java.lang.String.class, value)); return true;
- default: return false;
- }
- }
-
- @Override
- public Class<?> getOptionType(String name, boolean ignoreCase) {
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "accesskey":
- case "accessKey": return java.lang.String.class;
- case "autodiscoverclient":
- case "autoDiscoverClient": return boolean.class;
- case "eksclient":
- case "eksClient": return com.amazonaws.services.eks.AmazonEKS.class;
- case "lazystartproducer":
- case "lazyStartProducer": return boolean.class;
- case "operation": return org.apache.camel.component.aws.eks.EKSOperations.class;
- case "proxyhost":
- case "proxyHost": return java.lang.String.class;
- case "proxyport":
- case "proxyPort": return java.lang.Integer.class;
- case "proxyprotocol":
- case "proxyProtocol": return com.amazonaws.Protocol.class;
- case "region": return java.lang.String.class;
- case "secretkey":
- case "secretKey": return java.lang.String.class;
- default: return null;
- }
- }
-
- @Override
- public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
- EKSEndpoint target = (EKSEndpoint) obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "accesskey":
- case "accessKey": return target.getConfiguration().getAccessKey();
- case "autodiscoverclient":
- case "autoDiscoverClient": return target.getConfiguration().isAutoDiscoverClient();
- case "eksclient":
- case "eksClient": return target.getConfiguration().getEksClient();
- case "lazystartproducer":
- case "lazyStartProducer": return target.isLazyStartProducer();
- case "operation": return target.getConfiguration().getOperation();
- case "proxyhost":
- case "proxyHost": return target.getConfiguration().getProxyHost();
- case "proxyport":
- case "proxyPort": return target.getConfiguration().getProxyPort();
- case "proxyprotocol":
- case "proxyProtocol": return target.getConfiguration().getProxyProtocol();
- case "region": return target.getConfiguration().getRegion();
- case "secretkey":
- case "secretKey": return target.getConfiguration().getSecretKey();
- default: return null;
- }
- }
-}
-
diff --git a/components/camel-aws-eks/src/generated/java/org/apache/camel/component/aws/eks/EKSEndpointUriFactory.java b/components/camel-aws-eks/src/generated/java/org/apache/camel/component/aws/eks/EKSEndpointUriFactory.java
deleted file mode 100644
index 1d5f497..0000000
--- a/components/camel-aws-eks/src/generated/java/org/apache/camel/component/aws/eks/EKSEndpointUriFactory.java
+++ /dev/null
@@ -1,74 +0,0 @@
-/* Generated by camel build tools - do NOT edit this file! */
-package org.apache.camel.component.aws.eks;
-
-import java.net.URISyntaxException;
-import java.util.Collections;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.Map;
-import java.util.Set;
-
-import org.apache.camel.spi.EndpointUriFactory;
-
-/**
- * Generated by camel build tools - do NOT edit this file!
- */
-public class EKSEndpointUriFactory extends org.apache.camel.support.component.EndpointUriFactorySupport implements EndpointUriFactory {
-
- private static final String BASE = ":label";
-
- private static final Set<String> PROPERTY_NAMES;
- private static final Set<String> SECRET_PROPERTY_NAMES;
- static {
- Set<String> props = new HashSet<>(11);
- props.add("autoDiscoverClient");
- props.add("proxyPort");
- props.add("lazyStartProducer");
- props.add("proxyProtocol");
- props.add("secretKey");
- props.add("accessKey");
- props.add("eksClient");
- props.add("label");
- props.add("region");
- props.add("operation");
- props.add("proxyHost");
- PROPERTY_NAMES = Collections.unmodifiableSet(props);
- Set<String> secretProps = new HashSet<>(2);
- secretProps.add("secretKey");
- secretProps.add("accessKey");
- SECRET_PROPERTY_NAMES = Collections.unmodifiableSet(secretProps);
- }
-
- @Override
- public boolean isEnabled(String scheme) {
- return "aws-eks".equals(scheme);
- }
-
- @Override
- public String buildUri(String scheme, Map<String, Object> properties, boolean encode) throws URISyntaxException {
- String syntax = scheme + BASE;
- String uri = syntax;
-
- Map<String, Object> copy = new HashMap<>(properties);
-
- uri = buildPathParameter(syntax, uri, "label", null, true, copy);
- uri = buildQueryParameters(uri, copy, encode);
- return uri;
- }
-
- @Override
- public Set<String> propertyNames() {
- return PROPERTY_NAMES;
- }
-
- @Override
- public Set<String> secretPropertyNames() {
- return SECRET_PROPERTY_NAMES;
- }
-
- @Override
- public boolean isLenientProperties() {
- return false;
- }
-}
-
diff --git a/components/camel-aws-eks/src/generated/resources/META-INF/services/org/apache/camel/component.properties b/components/camel-aws-eks/src/generated/resources/META-INF/services/org/apache/camel/component.properties
deleted file mode 100644
index 0dc1b4c..0000000
--- a/components/camel-aws-eks/src/generated/resources/META-INF/services/org/apache/camel/component.properties
+++ /dev/null
@@ -1,7 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-components=aws-eks
-groupId=org.apache.camel
-artifactId=camel-aws-eks
-version=3.9.0-SNAPSHOT
-projectName=Camel :: AWS EKS (deprecated)
-projectDescription=A Camel Amazon EKS Web Service Component
diff --git a/components/camel-aws-eks/src/generated/resources/META-INF/services/org/apache/camel/component/aws-eks b/components/camel-aws-eks/src/generated/resources/META-INF/services/org/apache/camel/component/aws-eks
deleted file mode 100644
index 7e1aaa3..0000000
--- a/components/camel-aws-eks/src/generated/resources/META-INF/services/org/apache/camel/component/aws-eks
+++ /dev/null
@@ -1,2 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.aws.eks.EKSComponent
diff --git a/components/camel-aws-eks/src/generated/resources/META-INF/services/org/apache/camel/configurer/aws-eks-component b/components/camel-aws-eks/src/generated/resources/META-INF/services/org/apache/camel/configurer/aws-eks-component
deleted file mode 100644
index 6a21762..0000000
--- a/components/camel-aws-eks/src/generated/resources/META-INF/services/org/apache/camel/configurer/aws-eks-component
+++ /dev/null
@@ -1,2 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.aws.eks.EKSComponentConfigurer
diff --git a/components/camel-aws-eks/src/generated/resources/META-INF/services/org/apache/camel/configurer/aws-eks-endpoint b/components/camel-aws-eks/src/generated/resources/META-INF/services/org/apache/camel/configurer/aws-eks-endpoint
deleted file mode 100644
index 6662c94..0000000
--- a/components/camel-aws-eks/src/generated/resources/META-INF/services/org/apache/camel/configurer/aws-eks-endpoint
+++ /dev/null
@@ -1,2 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.aws.eks.EKSEndpointConfigurer
diff --git a/components/camel-aws-eks/src/generated/resources/META-INF/services/org/apache/camel/urifactory/aws-eks-endpoint b/components/camel-aws-eks/src/generated/resources/META-INF/services/org/apache/camel/urifactory/aws-eks-endpoint
deleted file mode 100644
index 9c370c9..0000000
--- a/components/camel-aws-eks/src/generated/resources/META-INF/services/org/apache/camel/urifactory/aws-eks-endpoint
+++ /dev/null
@@ -1,2 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.aws.eks.EKSEndpointUriFactory
diff --git a/components/camel-aws-eks/src/generated/resources/org/apache/camel/component/aws/eks/aws-eks.json b/components/camel-aws-eks/src/generated/resources/org/apache/camel/component/aws/eks/aws-eks.json
deleted file mode 100644
index 76bef36..0000000
--- a/components/camel-aws-eks/src/generated/resources/org/apache/camel/component/aws/eks/aws-eks.json
+++ /dev/null
@@ -1,52 +0,0 @@
-{
- "component": {
- "kind": "component",
- "name": "aws-eks",
- "title": "AWS Elastic Kubernetes Service (EKS)",
- "description": "Manage AWS EKS cluster instances.",
- "deprecated": true,
- "deprecatedSince": "3.8.0",
- "firstVersion": "3.0.0",
- "label": "cloud,management",
- "javaType": "org.apache.camel.component.aws.eks.EKSComponent",
- "supportLevel": "Stable",
- "groupId": "org.apache.camel",
- "artifactId": "camel-aws-eks",
- "version": "3.9.0-SNAPSHOT",
- "scheme": "aws-eks",
- "extendsScheme": "",
- "syntax": "aws-eks:label",
- "async": false,
- "api": false,
- "consumerOnly": false,
- "producerOnly": true,
- "lenientProperties": false
- },
- "componentProperties": {
- "autoDiscoverClient": { "kind": "property", "displayName": "Auto Discover Client", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instan [...]
- "accessKey": { "kind": "property", "displayName": "Access Key", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "Amazon AWS Access Key" },
- "configuration": { "kind": "property", "displayName": "Configuration", "group": "producer", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.aws.eks.EKSConfiguration", "deprecated": false, "autowired": false, "secret": false, "description": "The component configuration" },
- "eksClient": { "kind": "property", "displayName": "Eks Client", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "com.amazonaws.services.eks.AmazonEKS", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "To use a existing configured AWS EKS as client" },
- "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 [...]
- "operation": { "kind": "property", "displayName": "Operation", "group": "producer", "label": "producer", "required": true, "type": "object", "javaType": "org.apache.camel.component.aws.eks.EKSOperations", "enum": [ "listClusters", "describeCluster", "createCluster", "deleteCluster" ], "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "desc [...]
- "proxyHost": { "kind": "property", "displayName": "Proxy Host", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "To define a proxy host when instantiating the EKS client" },
- "proxyPort": { "kind": "property", "displayName": "Proxy Port", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "To define a proxy port when instantiating the EKS client" },
- "proxyProtocol": { "kind": "property", "displayName": "Proxy Protocol", "group": "producer", "label": "", "required": false, "type": "object", "javaType": "com.amazonaws.Protocol", "enum": [ "HTTP", "HTTPS" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "HTTPS", "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "To define a proxy protocol when instantiating the EKS client" },
- "region": { "kind": "property", "displayName": "Region", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "The region in which EKS client needs to work. When using this parameter, the configuration will expect the capitalized name of the region [...]
- "secretKey": { "kind": "property", "displayName": "Secret Key", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "Amazon AWS Secret Key" },
- "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 [...]
- },
- "properties": {
- "label": { "kind": "path", "displayName": "Label", "group": "producer", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "Logical name" },
- "autoDiscoverClient": { "kind": "parameter", "displayName": "Auto Discover Client", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client insta [...]
- "accessKey": { "kind": "parameter", "displayName": "Access Key", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "Amazon AWS Access Key" },
- "eksClient": { "kind": "parameter", "displayName": "Eks Client", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "com.amazonaws.services.eks.AmazonEKS", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "To use a existing configured AWS EKS as client" },
- "lazyStartProducer": { "kind": "parameter", "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 sta [...]
- "operation": { "kind": "parameter", "displayName": "Operation", "group": "producer", "label": "producer", "required": true, "type": "object", "javaType": "org.apache.camel.component.aws.eks.EKSOperations", "enum": [ "listClusters", "describeCluster", "createCluster", "deleteCluster" ], "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "des [...]
- "proxyHost": { "kind": "parameter", "displayName": "Proxy Host", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "To define a proxy host when instantiating the EKS client" },
- "proxyPort": { "kind": "parameter", "displayName": "Proxy Port", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "To define a proxy port when instantiating the EKS client" },
- "proxyProtocol": { "kind": "parameter", "displayName": "Proxy Protocol", "group": "producer", "label": "", "required": false, "type": "object", "javaType": "com.amazonaws.Protocol", "enum": [ "HTTP", "HTTPS" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "HTTPS", "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "To define a proxy protocol when instantiating the EKS client" },
- "region": { "kind": "parameter", "displayName": "Region", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "The region in which EKS client needs to work. When using this parameter, the configuration will expect the capitalized name of the region [...]
- "secretKey": { "kind": "parameter", "displayName": "Secret Key", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.aws.eks.EKSConfiguration", "configurationField": "configuration", "description": "Amazon AWS Secret Key" }
- }
-}
diff --git a/components/camel-aws-eks/src/main/docs/aws-eks-component.adoc b/components/camel-aws-eks/src/main/docs/aws-eks-component.adoc
deleted file mode 100644
index 0572448..0000000
--- a/components/camel-aws-eks/src/main/docs/aws-eks-component.adoc
+++ /dev/null
@@ -1,177 +0,0 @@
-[[aws-eks-component]]
-= AWS Elastic Kubernetes Service (EKS) Component (deprecated)
-:docTitle: AWS Elastic Kubernetes Service (EKS)
-:artifactId: camel-aws-eks
-:description: Manage AWS EKS cluster instances.
-:since: 3.0
-:supportLevel: Stable-deprecated
-:deprecated: *deprecated*
-:component-header: Only producer is supported
-include::{cq-version}@camel-quarkus:ROOT:partial$reference/components/aws-eks.adoc[opts=optional]
-//Manually maintained attributes
-:group: AWS
-
-*Since Camel {since}*
-
-*{component-header}*
-
-The EKS component supports create, delete, describe and list
-https://aws.amazon.com/eks/[AWS EKS] clusters instances.
-
-Prerequisites
-
-You must have a valid Amazon Web Services developer account, and be
-signed up to use Amazon EKS. More information is available at
-https://aws.amazon.com/eks/[Amazon EKS].
-
-== URI Format
-
-[source,java]
--------------------------
-aws-eks://label[?options]
--------------------------
-
-You can append query options to the URI in the following format,
-?options=value&option2=value&...
-
-== URI Options
-
-
-// component options: START
-The AWS Elastic Kubernetes Service (EKS) component supports 12 options, which are listed below.
-
-
-
-[width="100%",cols="2,5,^1,2",options="header"]
-|===
-| Name | Description | Default | Type
-| *autoDiscoverClient* (common) | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | boolean
-| *accessKey* (producer) | Amazon AWS Access Key | | String
-| *configuration* (producer) | The component configuration | | EKSConfiguration
-| *eksClient* (producer) | To use a existing configured AWS EKS as client | | AmazonEKS
-| *lazyStartProducer* (producer) | 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 [...]
-| *operation* (producer) | *Required* The operation to perform. There are 4 enums and the value can be one of: listClusters, describeCluster, createCluster, deleteCluster | | EKSOperations
-| *proxyHost* (producer) | To define a proxy host when instantiating the EKS client | | String
-| *proxyPort* (producer) | To define a proxy port when instantiating the EKS client | | Integer
-| *proxyProtocol* (producer) | To define a proxy protocol when instantiating the EKS client. There are 2 enums and the value can be one of: HTTP, HTTPS | HTTPS | Protocol
-| *region* (producer) | The region in which EKS client needs to work. When using this parameter, the configuration will expect the capitalized name of the region (for example AP_EAST_1) You'll need to use the name Regions.EU_WEST_1.name() | | String
-| *secretKey* (producer) | Amazon AWS Secret Key | | String
-| *autowiredEnabled* (advanced) | 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. | true | boolean
-|===
-// component options: END
-
-
-
-
-// endpoint options: START
-The AWS Elastic Kubernetes Service (EKS) endpoint is configured using URI syntax:
-
-----
-aws-eks:label
-----
-
-with the following path and query parameters:
-
-=== Path Parameters (1 parameters):
-
-
-[width="100%",cols="2,5,^1,2",options="header"]
-|===
-| Name | Description | Default | Type
-| *label* | *Required* Logical name | | String
-|===
-
-
-=== Query Parameters (10 parameters):
-
-
-[width="100%",cols="2,5,^1,2",options="header"]
-|===
-| Name | Description | Default | Type
-| *autoDiscoverClient* (common) | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | boolean
-| *accessKey* (producer) | Amazon AWS Access Key | | String
-| *eksClient* (producer) | To use a existing configured AWS EKS as client | | AmazonEKS
-| *lazyStartProducer* (producer) | 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 [...]
-| *operation* (producer) | *Required* The operation to perform. There are 4 enums and the value can be one of: listClusters, describeCluster, createCluster, deleteCluster | | EKSOperations
-| *proxyHost* (producer) | To define a proxy host when instantiating the EKS client | | String
-| *proxyPort* (producer) | To define a proxy port when instantiating the EKS client | | Integer
-| *proxyProtocol* (producer) | To define a proxy protocol when instantiating the EKS client. There are 2 enums and the value can be one of: HTTP, HTTPS | HTTPS | Protocol
-| *region* (producer) | The region in which EKS client needs to work. When using this parameter, the configuration will expect the capitalized name of the region (for example AP_EAST_1) You'll need to use the name Regions.EU_WEST_1.name() | | String
-| *secretKey* (producer) | Amazon AWS Secret Key | | String
-|===
-// endpoint options: END
-
-
-
-
-Required EKS component options
-
-You have to provide the amazonEKSClient in the
-Registry or your accessKey and secretKey to access
-the https://aws.amazon.com/eks/[Amazon EKS] service.
-
-== Usage
-
-=== Message headers evaluated by the EKS producer
-
-[width="100%",cols="10%,10%,80%",options="header",]
-|=======================================================================
-|Header |Type |Description
-
-|`CamelAwsEKSMaxResults` |`Integer` |The limit number of results while listing clusters
-
-|`CamelAwsEKSOperation` |`String` |The operation we want to perform
-
-|`CamelAwsEKSDescription` |`String` |A key description to use while performing a createKey operation
-
-|`CamelAwsEKSClusterName` |`String` |The cluster name
-
-|`CamelAwsEKSRoleARN` |`String` |The role ARN to use while creating the cluster
-
-|`CamelAwsEKSVPCConfig` |`VPCConfigRequest` |The VPC config for the creations of an EKS cluster
-|=======================================================================
-
-=== EKS Producer operations
-
-Camel-AWS EKS component provides the following operation on the producer side:
-
-- listClusters
-- createCluster
-- describeCluster
-- deleteCluster
-
-== Producer Examples
-
-- listClusters: this operation will list the available clusters in EKS
-
-[source,java]
---------------------------------------------------------------------------------
-from("direct:listClusters")
- .to("aws-eks://test?ecsClient=#amazonEksClient&operation=listClusters")
---------------------------------------------------------------------------------
-
-== Automatic detection of AmazonEKS client in registry
-
-The component is capable of detecting the presence of an AmazonEKS bean into the registry.
-If it's the only instance of that type it will be used as client and you won't have to define it as uri parameter.
-This may be really useful for smarter configuration of the endpoint.
-
-Dependencies
-
-Maven users will need to add the following dependency to their pom.xml.
-
-*pom.xml*
-
-[source,xml]
----------------------------------------
-<dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-aws-eks</artifactId>
- <version>${camel-version}</version>
-</dependency>
----------------------------------------
-
-where `$\{camel-version}` must be replaced by the actual version of Camel.
-
-
-include::camel-spring-boot::page$aws-eks-starter.adoc[]
diff --git a/components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSComponent.java b/components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSComponent.java
deleted file mode 100644
index 83bc632..0000000
--- a/components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSComponent.java
+++ /dev/null
@@ -1,81 +0,0 @@
-/*
- * 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.component.aws.eks;
-
-import java.util.Map;
-import java.util.Set;
-
-import com.amazonaws.services.eks.AmazonEKS;
-import org.apache.camel.CamelContext;
-import org.apache.camel.Endpoint;
-import org.apache.camel.spi.Metadata;
-import org.apache.camel.spi.annotations.Component;
-import org.apache.camel.support.DefaultComponent;
-
-/**
- * For working with Amazon EKS.
- */
-@Component("aws-eks")
-public class EKSComponent extends DefaultComponent {
-
- @Metadata
- private EKSConfiguration configuration = new EKSConfiguration();
-
- public EKSComponent() {
- this(null);
- }
-
- public EKSComponent(CamelContext context) {
- super(context);
-
- registerExtension(new EKSComponentVerifierExtension());
- }
-
- @Override
- protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) throws Exception {
- EKSConfiguration configuration = this.configuration != null ? this.configuration.copy() : new EKSConfiguration();
- EKSEndpoint endpoint = new EKSEndpoint(uri, this, configuration);
- setProperties(endpoint, parameters);
- if (endpoint.getConfiguration().isAutoDiscoverClient()) {
- checkAndSetRegistryClient(configuration);
- }
- if (configuration.getEksClient() == null
- && (configuration.getAccessKey() == null || configuration.getSecretKey() == null)) {
- throw new IllegalArgumentException("Amazon eks client or accessKey and secretKey must be specified");
- }
-
- return endpoint;
- }
-
- public EKSConfiguration getConfiguration() {
- return configuration;
- }
-
- /**
- * The component configuration
- */
- public void setConfiguration(EKSConfiguration configuration) {
- this.configuration = configuration;
- }
-
- private void checkAndSetRegistryClient(EKSConfiguration configuration) {
- Set<AmazonEKS> clients = getCamelContext().getRegistry().findByType(AmazonEKS.class);
- if (clients.size() == 1) {
- configuration.setEksClient(clients.stream().findFirst().get());
- }
- }
-}
diff --git a/components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSComponentVerifierExtension.java b/components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSComponentVerifierExtension.java
deleted file mode 100644
index eeb8aa0..0000000
--- a/components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSComponentVerifierExtension.java
+++ /dev/null
@@ -1,92 +0,0 @@
-/*
- * 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.component.aws.eks;
-
-import java.util.Map;
-
-import com.amazonaws.SdkClientException;
-import com.amazonaws.auth.AWSCredentials;
-import com.amazonaws.auth.AWSCredentialsProvider;
-import com.amazonaws.auth.AWSStaticCredentialsProvider;
-import com.amazonaws.auth.BasicAWSCredentials;
-import com.amazonaws.regions.Regions;
-import com.amazonaws.services.eks.AmazonEKS;
-import com.amazonaws.services.eks.AmazonEKSClientBuilder;
-import com.amazonaws.services.eks.model.ListClustersRequest;
-import org.apache.camel.component.extension.verifier.DefaultComponentVerifierExtension;
-import org.apache.camel.component.extension.verifier.ResultBuilder;
-import org.apache.camel.component.extension.verifier.ResultErrorBuilder;
-import org.apache.camel.component.extension.verifier.ResultErrorHelper;
-
-public class EKSComponentVerifierExtension extends DefaultComponentVerifierExtension {
-
- public EKSComponentVerifierExtension() {
- this("aws-eks");
- }
-
- public EKSComponentVerifierExtension(String scheme) {
- super(scheme);
- }
-
- // *********************************
- // Parameters validation
- // *********************************
-
- @Override
- protected Result verifyParameters(Map<String, Object> parameters) {
-
- ResultBuilder builder = ResultBuilder.withStatusAndScope(Result.Status.OK, Scope.PARAMETERS)
- .error(ResultErrorHelper.requiresOption("accessKey", parameters))
- .error(ResultErrorHelper.requiresOption("secretKey", parameters))
- .error(ResultErrorHelper.requiresOption("region", parameters));
-
- // Validate using the catalog
-
- super.verifyParametersAgainstCatalog(builder, parameters);
-
- return builder.build();
- }
-
- // *********************************
- // Connectivity validation
- // *********************************
-
- @Override
- protected Result verifyConnectivity(Map<String, Object> parameters) {
- ResultBuilder builder = ResultBuilder.withStatusAndScope(Result.Status.OK, Scope.CONNECTIVITY);
-
- try {
- EKSConfiguration configuration = setProperties(new EKSConfiguration(), parameters);
- AWSCredentials credentials = new BasicAWSCredentials(configuration.getAccessKey(), configuration.getSecretKey());
- AWSCredentialsProvider credentialsProvider = new AWSStaticCredentialsProvider(credentials);
- AmazonEKS client = AmazonEKSClientBuilder.standard().withCredentials(credentialsProvider)
- .withRegion(Regions.valueOf(configuration.getRegion())).build();
- client.listClusters(new ListClustersRequest());
- } catch (SdkClientException e) {
- ResultErrorBuilder errorBuilder
- = ResultErrorBuilder.withCodeAndDescription(VerificationError.StandardCode.AUTHENTICATION, e.getMessage())
- .detail("aws_eks_exception_message", e.getMessage())
- .detail(VerificationError.ExceptionAttribute.EXCEPTION_CLASS, e.getClass().getName())
- .detail(VerificationError.ExceptionAttribute.EXCEPTION_INSTANCE, e);
-
- builder.error(errorBuilder.build());
- } catch (Exception e) {
- builder.error(ResultErrorBuilder.withException(e).build());
- }
- return builder.build();
- }
-}
diff --git a/components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSConfiguration.java b/components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSConfiguration.java
deleted file mode 100644
index 7cb8548..0000000
--- a/components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSConfiguration.java
+++ /dev/null
@@ -1,165 +0,0 @@
-/*
- * 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.component.aws.eks;
-
-import com.amazonaws.Protocol;
-import com.amazonaws.services.eks.AmazonEKS;
-import org.apache.camel.RuntimeCamelException;
-import org.apache.camel.spi.Metadata;
-import org.apache.camel.spi.UriParam;
-import org.apache.camel.spi.UriParams;
-import org.apache.camel.spi.UriPath;
-
-@UriParams
-public class EKSConfiguration implements Cloneable {
-
- @UriPath(description = "Logical name")
- @Metadata(required = true)
- private String label;
- @UriParam(label = "producer")
- private AmazonEKS eksClient;
- @UriParam(label = "producer", secret = true)
- private String accessKey;
- @UriParam(label = "producer", secret = true)
- private String secretKey;
- @UriParam(label = "producer")
- @Metadata(required = true)
- private EKSOperations operation;
- @UriParam(enums = "HTTP,HTTPS", defaultValue = "HTTPS")
- private Protocol proxyProtocol = Protocol.HTTPS;
- @UriParam(label = "producer")
- private String proxyHost;
- @UriParam(label = "producer")
- private Integer proxyPort;
- @UriParam
- private String region;
- @UriParam(label = "common", defaultValue = "true")
- private boolean autoDiscoverClient = true;
-
- public AmazonEKS getEksClient() {
- return eksClient;
- }
-
- /**
- * To use a existing configured AWS EKS as client
- */
- public void setEksClient(AmazonEKS eksClient) {
- this.eksClient = eksClient;
- }
-
- public String getAccessKey() {
- return accessKey;
- }
-
- /**
- * Amazon AWS Access Key
- */
- public void setAccessKey(String accessKey) {
- this.accessKey = accessKey;
- }
-
- public String getSecretKey() {
- return secretKey;
- }
-
- /**
- * Amazon AWS Secret Key
- */
- public void setSecretKey(String secretKey) {
- this.secretKey = secretKey;
- }
-
- public EKSOperations getOperation() {
- return operation;
- }
-
- /**
- * The operation to perform
- */
- public void setOperation(EKSOperations operation) {
- this.operation = operation;
- }
-
- public Protocol getProxyProtocol() {
- return proxyProtocol;
- }
-
- /**
- * To define a proxy protocol when instantiating the EKS client
- */
- public void setProxyProtocol(Protocol proxyProtocol) {
- this.proxyProtocol = proxyProtocol;
- }
-
- public String getProxyHost() {
- return proxyHost;
- }
-
- /**
- * To define a proxy host when instantiating the EKS client
- */
- public void setProxyHost(String proxyHost) {
- this.proxyHost = proxyHost;
- }
-
- public Integer getProxyPort() {
- return proxyPort;
- }
-
- /**
- * To define a proxy port when instantiating the EKS client
- */
- public void setProxyPort(Integer proxyPort) {
- this.proxyPort = proxyPort;
- }
-
- public String getRegion() {
- return region;
- }
-
- /**
- * The region in which EKS client needs to work. When using this parameter, the configuration will expect the
- * capitalized name of the region (for example AP_EAST_1) You'll need to use the name Regions.EU_WEST_1.name()
- */
- public void setRegion(String region) {
- this.region = region;
- }
-
- public boolean isAutoDiscoverClient() {
- return autoDiscoverClient;
- }
-
- /**
- * Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry
- * automatically otherwise it will skip that checking.
- */
- public void setAutoDiscoverClient(boolean autoDiscoverClient) {
- this.autoDiscoverClient = autoDiscoverClient;
- }
-
- // *************************************************
- //
- // *************************************************
-
- public EKSConfiguration copy() {
- try {
- return (EKSConfiguration) super.clone();
- } catch (CloneNotSupportedException e) {
- throw new RuntimeCamelException(e);
- }
- }
-}
diff --git a/components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSConstants.java b/components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSConstants.java
deleted file mode 100644
index 5ffa766..0000000
--- a/components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSConstants.java
+++ /dev/null
@@ -1,29 +0,0 @@
-/*
- * 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.component.aws.eks;
-
-/**
- * Constants used in Camel AWS EKS module
- */
-public interface EKSConstants {
- String OPERATION = "CamelAwsEKSOperation";
- String MAX_RESULTS = "CamelAwsEKSMaxResults";
- String DESCRIPTION = "CamelAwsEKSDescription";
- String CLUSTER_NAME = "CamelAwsEKSClusterName";
- String ROLE_ARN = "CamelAwsEKSRoleARN";
- String VPC_CONFIG = "CamelAwsEKSVPCConfig";
-}
diff --git a/components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSEndpoint.java b/components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSEndpoint.java
deleted file mode 100644
index 72cfcfe..0000000
--- a/components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSEndpoint.java
+++ /dev/null
@@ -1,123 +0,0 @@
-/*
- * 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.component.aws.eks;
-
-import com.amazonaws.ClientConfiguration;
-import com.amazonaws.auth.AWSCredentials;
-import com.amazonaws.auth.AWSCredentialsProvider;
-import com.amazonaws.auth.AWSStaticCredentialsProvider;
-import com.amazonaws.auth.BasicAWSCredentials;
-import com.amazonaws.regions.Regions;
-import com.amazonaws.services.eks.AmazonEKS;
-import com.amazonaws.services.eks.AmazonEKSClientBuilder;
-import org.apache.camel.Category;
-import org.apache.camel.Component;
-import org.apache.camel.Consumer;
-import org.apache.camel.Processor;
-import org.apache.camel.Producer;
-import org.apache.camel.spi.UriEndpoint;
-import org.apache.camel.spi.UriParam;
-import org.apache.camel.support.ScheduledPollEndpoint;
-import org.apache.camel.util.ObjectHelper;
-
-/**
- * Manage AWS EKS cluster instances.
- */
-@UriEndpoint(firstVersion = "3.0.0", scheme = "aws-eks", title = "AWS Elastic Kubernetes Service (EKS)",
- syntax = "aws-eks:label", producerOnly = true, category = { Category.CLOUD, Category.MANAGEMENT })
-public class EKSEndpoint extends ScheduledPollEndpoint {
-
- private AmazonEKS eksClient;
-
- @UriParam
- private EKSConfiguration configuration;
-
- public EKSEndpoint(String uri, Component component, EKSConfiguration configuration) {
- super(uri, component);
- this.configuration = configuration;
- }
-
- @Override
- public Consumer createConsumer(Processor processor) throws Exception {
- throw new UnsupportedOperationException("You cannot receive messages from this endpoint");
- }
-
- @Override
- public Producer createProducer() throws Exception {
- return new EKSProducer(this);
- }
-
- @Override
- public void doStart() throws Exception {
- super.doStart();
-
- eksClient = configuration.getEksClient() != null ? configuration.getEksClient() : createEKSClient();
- }
-
- @Override
- public void doStop() throws Exception {
- if (ObjectHelper.isEmpty(configuration.getEksClient())) {
- if (eksClient != null) {
- eksClient.shutdown();
- }
- }
- super.doStop();
- }
-
- public EKSConfiguration getConfiguration() {
- return configuration;
- }
-
- public AmazonEKS getEksClient() {
- return eksClient;
- }
-
- AmazonEKS createEKSClient() {
- AmazonEKS client = null;
- ClientConfiguration clientConfiguration = null;
- AmazonEKSClientBuilder clientBuilder = null;
- boolean isClientConfigFound = false;
- if (ObjectHelper.isNotEmpty(configuration.getProxyHost()) && ObjectHelper.isNotEmpty(configuration.getProxyPort())) {
- clientConfiguration = new ClientConfiguration();
- clientConfiguration.setProxyProtocol(configuration.getProxyProtocol());
- clientConfiguration.setProxyHost(configuration.getProxyHost());
- clientConfiguration.setProxyPort(configuration.getProxyPort());
- isClientConfigFound = true;
- }
- if (configuration.getAccessKey() != null && configuration.getSecretKey() != null) {
- AWSCredentials credentials = new BasicAWSCredentials(configuration.getAccessKey(), configuration.getSecretKey());
- AWSCredentialsProvider credentialsProvider = new AWSStaticCredentialsProvider(credentials);
- if (isClientConfigFound) {
- clientBuilder = AmazonEKSClientBuilder.standard().withClientConfiguration(clientConfiguration)
- .withCredentials(credentialsProvider);
- } else {
- clientBuilder = AmazonEKSClientBuilder.standard().withCredentials(credentialsProvider);
- }
- } else {
- if (isClientConfigFound) {
- clientBuilder = AmazonEKSClientBuilder.standard();
- } else {
- clientBuilder = AmazonEKSClientBuilder.standard().withClientConfiguration(clientConfiguration);
- }
- }
- if (ObjectHelper.isNotEmpty(configuration.getRegion())) {
- clientBuilder = clientBuilder.withRegion(Regions.valueOf(configuration.getRegion()));
- }
- client = clientBuilder.build();
- return client;
- }
-}
diff --git a/components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSOperations.java b/components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSOperations.java
deleted file mode 100644
index cc5aba9..0000000
--- a/components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSOperations.java
+++ /dev/null
@@ -1,25 +0,0 @@
-/*
- * 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.component.aws.eks;
-
-public enum EKSOperations {
-
- listClusters,
- describeCluster,
- createCluster,
- deleteCluster
-}
diff --git a/components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSProducer.java b/components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSProducer.java
deleted file mode 100644
index 7352036..0000000
--- a/components/camel-aws-eks/src/main/java/org/apache/camel/component/aws/eks/EKSProducer.java
+++ /dev/null
@@ -1,179 +0,0 @@
-/*
- * 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.component.aws.eks;
-
-import com.amazonaws.AmazonServiceException;
-import com.amazonaws.services.eks.AmazonEKS;
-import com.amazonaws.services.eks.model.CreateClusterRequest;
-import com.amazonaws.services.eks.model.CreateClusterResult;
-import com.amazonaws.services.eks.model.DeleteClusterRequest;
-import com.amazonaws.services.eks.model.DeleteClusterResult;
-import com.amazonaws.services.eks.model.DescribeClusterRequest;
-import com.amazonaws.services.eks.model.DescribeClusterResult;
-import com.amazonaws.services.eks.model.ListClustersRequest;
-import com.amazonaws.services.eks.model.ListClustersResult;
-import com.amazonaws.services.eks.model.VpcConfigRequest;
-import org.apache.camel.Endpoint;
-import org.apache.camel.Exchange;
-import org.apache.camel.Message;
-import org.apache.camel.support.DefaultProducer;
-import org.apache.camel.util.ObjectHelper;
-import org.apache.camel.util.URISupport;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * A Producer which sends messages to the Amazon EKS Service <a href="http://aws.amazon.com/eks/">AWS EKS</a>
- */
-public class EKSProducer extends DefaultProducer {
-
- private static final Logger LOG = LoggerFactory.getLogger(EKSProducer.class);
- private transient String eksProducerToString;
-
- public EKSProducer(Endpoint endpoint) {
- super(endpoint);
- }
-
- @Override
- public void process(Exchange exchange) throws Exception {
- switch (determineOperation(exchange)) {
- case listClusters:
- listClusters(getEndpoint().getEksClient(), exchange);
- break;
- case describeCluster:
- describeCluster(getEndpoint().getEksClient(), exchange);
- break;
- case createCluster:
- createCluster(getEndpoint().getEksClient(), exchange);
- break;
- case deleteCluster:
- deleteCluster(getEndpoint().getEksClient(), exchange);
- break;
- default:
- throw new IllegalArgumentException("Unsupported operation");
- }
- }
-
- private EKSOperations determineOperation(Exchange exchange) {
- EKSOperations operation = exchange.getIn().getHeader(EKSConstants.OPERATION, EKSOperations.class);
- if (operation == null) {
- operation = getConfiguration().getOperation();
- }
- return operation;
- }
-
- protected EKSConfiguration getConfiguration() {
- return getEndpoint().getConfiguration();
- }
-
- @Override
- public String toString() {
- if (eksProducerToString == null) {
- eksProducerToString = "EKSProducer[" + URISupport.sanitizeUri(getEndpoint().getEndpointUri()) + "]";
- }
- return eksProducerToString;
- }
-
- @Override
- public EKSEndpoint getEndpoint() {
- return (EKSEndpoint) super.getEndpoint();
- }
-
- private void listClusters(AmazonEKS eksClient, Exchange exchange) {
- ListClustersRequest request = new ListClustersRequest();
- if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(EKSConstants.MAX_RESULTS))) {
- int maxRes = exchange.getIn().getHeader(EKSConstants.MAX_RESULTS, Integer.class);
- request.withMaxResults(maxRes);
- }
- ListClustersResult result;
- try {
- result = eksClient.listClusters(request);
- } catch (AmazonServiceException ase) {
- LOG.trace("List Clusters command returned the error code {}", ase.getErrorCode());
- throw ase;
- }
- Message message = getMessageForResponse(exchange);
- message.setBody(result);
- }
-
- private void createCluster(AmazonEKS eksClient, Exchange exchange) {
- CreateClusterRequest request = new CreateClusterRequest();
- if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(EKSConstants.CLUSTER_NAME))) {
- String name = exchange.getIn().getHeader(EKSConstants.CLUSTER_NAME, String.class);
- request.withName(name);
- }
- if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(EKSConstants.ROLE_ARN))) {
- String roleArn = exchange.getIn().getHeader(EKSConstants.ROLE_ARN, String.class);
- request.withRoleArn(roleArn);
- }
- if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(EKSConstants.VPC_CONFIG))) {
- VpcConfigRequest vpcConfig = exchange.getIn().getHeader(EKSConstants.VPC_CONFIG, VpcConfigRequest.class);
- request.withResourcesVpcConfig(vpcConfig);
- }
- CreateClusterResult result;
- try {
- result = eksClient.createCluster(request);
- } catch (AmazonServiceException ase) {
- LOG.trace("Create Cluster command returned the error code {}", ase.getErrorCode());
- throw ase;
- }
- Message message = getMessageForResponse(exchange);
- message.setBody(result);
- }
-
- private void describeCluster(AmazonEKS eksClient, Exchange exchange) {
- DescribeClusterRequest request = new DescribeClusterRequest();
- if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(EKSConstants.CLUSTER_NAME))) {
- String name = exchange.getIn().getHeader(EKSConstants.CLUSTER_NAME, String.class);
- request.withName(name);
- } else {
- throw new IllegalArgumentException("Cluster name must be specified");
- }
- DescribeClusterResult result;
- try {
- result = eksClient.describeCluster(request);
- } catch (AmazonServiceException ase) {
- LOG.trace("Describe Cluster command returned the error code {}", ase.getErrorCode());
- throw ase;
- }
- Message message = getMessageForResponse(exchange);
- message.setBody(result);
- }
-
- private void deleteCluster(AmazonEKS eksClient, Exchange exchange) {
- DeleteClusterRequest request = new DeleteClusterRequest();
- if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(EKSConstants.CLUSTER_NAME))) {
- String name = exchange.getIn().getHeader(EKSConstants.CLUSTER_NAME, String.class);
- request.withName(name);
- } else {
- throw new IllegalArgumentException("Cluster name must be specified");
- }
- DeleteClusterResult result;
- try {
- result = eksClient.deleteCluster(request);
- } catch (AmazonServiceException ase) {
- LOG.trace("Delete Cluster command returned the error code {}", ase.getErrorCode());
- throw ase;
- }
- Message message = getMessageForResponse(exchange);
- message.setBody(result);
- }
-
- public static Message getMessageForResponse(final Exchange exchange) {
- return exchange.getMessage();
- }
-}
diff --git a/components/camel-aws-eks/src/test/java/org/apache/camel/component/aws/eks/AmazonEKSClientMock.java b/components/camel-aws-eks/src/test/java/org/apache/camel/component/aws/eks/AmazonEKSClientMock.java
deleted file mode 100644
index 176d133..0000000
--- a/components/camel-aws-eks/src/test/java/org/apache/camel/component/aws/eks/AmazonEKSClientMock.java
+++ /dev/null
@@ -1,77 +0,0 @@
-/*
- * 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.component.aws.eks;
-
-import java.util.ArrayList;
-import java.util.List;
-
-import com.amazonaws.services.eks.AbstractAmazonEKS;
-import com.amazonaws.services.eks.model.Cluster;
-import com.amazonaws.services.eks.model.ClusterStatus;
-import com.amazonaws.services.eks.model.CreateClusterRequest;
-import com.amazonaws.services.eks.model.CreateClusterResult;
-import com.amazonaws.services.eks.model.DeleteClusterRequest;
-import com.amazonaws.services.eks.model.DeleteClusterResult;
-import com.amazonaws.services.eks.model.DescribeClusterRequest;
-import com.amazonaws.services.eks.model.DescribeClusterResult;
-import com.amazonaws.services.eks.model.ListClustersRequest;
-import com.amazonaws.services.eks.model.ListClustersResult;
-
-public class AmazonEKSClientMock extends AbstractAmazonEKS {
-
- public AmazonEKSClientMock() {
- }
-
- @Override
- public CreateClusterResult createCluster(CreateClusterRequest request) {
- CreateClusterResult res = new CreateClusterResult();
- Cluster cluster = new Cluster();
- cluster.setName("Test");
- cluster.setStatus(ClusterStatus.ACTIVE.name());
- res.setCluster(cluster);
- return res;
- }
-
- @Override
- public DeleteClusterResult deleteCluster(DeleteClusterRequest request) {
- DeleteClusterResult res = new DeleteClusterResult();
- Cluster cluster = new Cluster();
- cluster.setName("Test");
- cluster.setStatus(ClusterStatus.DELETING.name());
- res.setCluster(cluster);
- return res;
- }
-
- @Override
- public DescribeClusterResult describeCluster(DescribeClusterRequest request) {
- DescribeClusterResult res = new DescribeClusterResult();
- Cluster cluster = new Cluster();
- cluster.setName("Test");
- cluster.setStatus(ClusterStatus.ACTIVE.name());
- res.setCluster(cluster);
- return res;
- }
-
- @Override
- public ListClustersResult listClusters(ListClustersRequest request) {
- ListClustersResult res = new ListClustersResult();
- List<String> list = new ArrayList<>();
- list.add("Test");
- res.setClusters(list);
- return res;
- }
-}
diff --git a/components/camel-aws-eks/src/test/java/org/apache/camel/component/aws/eks/EKSComponentClientRegistryTest.java b/components/camel-aws-eks/src/test/java/org/apache/camel/component/aws/eks/EKSComponentClientRegistryTest.java
deleted file mode 100644
index eae6647..0000000
--- a/components/camel-aws-eks/src/test/java/org/apache/camel/component/aws/eks/EKSComponentClientRegistryTest.java
+++ /dev/null
@@ -1,70 +0,0 @@
-/*
- * 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.component.aws.eks;
-
-import org.apache.camel.test.junit5.CamelTestSupport;
-import org.junit.jupiter.api.Test;
-
-import static org.junit.jupiter.api.Assertions.assertNotNull;
-import static org.junit.jupiter.api.Assertions.assertNotSame;
-import static org.junit.jupiter.api.Assertions.assertSame;
-import static org.junit.jupiter.api.Assertions.assertThrows;
-
-public class EKSComponentClientRegistryTest extends CamelTestSupport {
-
- @Test
- public void createEndpointWithMinimalECSClientConfiguration() throws Exception {
-
- AmazonEKSClientMock clientMock = new AmazonEKSClientMock();
- context.getRegistry().bind("amazonEcsClient", clientMock);
- EKSComponent component = context.getComponent("aws-eks", EKSComponent.class);
- EKSEndpoint endpoint = (EKSEndpoint) component.createEndpoint("aws-eks://TestDomain");
-
- assertNotNull(endpoint.getConfiguration().getEksClient());
- }
-
- @Test
- public void createEndpointWithMinimalECSClientMisconfiguration() throws Exception {
-
- EKSComponent component = context.getComponent("aws-eks", EKSComponent.class);
- assertThrows(IllegalArgumentException.class,
- () -> component.createEndpoint("aws-eks://TestDomain"));
- }
-
- @Test
- public void createEndpointWithAutoDiscoverClientFalse() throws Exception {
-
- AmazonEKSClientMock clientMock = new AmazonEKSClientMock();
- context.getRegistry().bind("amazonEcsClient", clientMock);
- EKSComponent component = context.getComponent("aws-eks", EKSComponent.class);
- EKSEndpoint endpoint = (EKSEndpoint) component
- .createEndpoint("aws-eks://TestDomain?accessKey=xxx&secretKey=yyyy&autoDiscoverClient=false");
-
- assertNotSame(clientMock, endpoint.getConfiguration().getEksClient());
- }
-
- @Test
- public void createEndpointWithAutoDiscoverClientTrue() throws Exception {
-
- AmazonEKSClientMock clientMock = new AmazonEKSClientMock();
- context.getRegistry().bind("amazonEcsClient", clientMock);
- EKSComponent component = context.getComponent("aws-eks", EKSComponent.class);
- EKSEndpoint endpoint = (EKSEndpoint) component.createEndpoint("aws-eks://TestDomain?accessKey=xxx&secretKey=yyyy");
-
- assertSame(clientMock, endpoint.getConfiguration().getEksClient());
- }
-}
diff --git a/components/camel-aws-eks/src/test/java/org/apache/camel/component/aws/eks/EKSComponentConfigurationTest.java b/components/camel-aws-eks/src/test/java/org/apache/camel/component/aws/eks/EKSComponentConfigurationTest.java
deleted file mode 100644
index 9b9f043..0000000
--- a/components/camel-aws-eks/src/test/java/org/apache/camel/component/aws/eks/EKSComponentConfigurationTest.java
+++ /dev/null
@@ -1,69 +0,0 @@
-/*
- * 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.component.aws.eks;
-
-import com.amazonaws.Protocol;
-import com.amazonaws.regions.Regions;
-import org.apache.camel.test.junit5.CamelTestSupport;
-import org.junit.jupiter.api.Test;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-
-public class EKSComponentConfigurationTest extends CamelTestSupport {
-
- @Test
- public void createEndpointWithComponentElements() throws Exception {
- EKSComponent component = context.getComponent("aws-eks", EKSComponent.class);
- component.getConfiguration().setAccessKey("XXX");
- component.getConfiguration().setSecretKey("YYY");
- EKSEndpoint endpoint = (EKSEndpoint) component.createEndpoint("aws-eks://label");
-
- assertEquals("XXX", endpoint.getConfiguration().getAccessKey());
- assertEquals("YYY", endpoint.getConfiguration().getSecretKey());
- }
-
- @Test
- public void createEndpointWithComponentAndEndpointElements() throws Exception {
- EKSComponent component = context.getComponent("aws-eks", EKSComponent.class);
- component.getConfiguration().setAccessKey("XXX");
- component.getConfiguration().setSecretKey("YYY");
- component.getConfiguration().setRegion(Regions.US_WEST_1.toString());
- EKSEndpoint endpoint
- = (EKSEndpoint) component.createEndpoint("aws-eks://label?accessKey=xxxxxx&secretKey=yyyyy®ion=US_EAST_1");
-
- assertEquals("xxxxxx", endpoint.getConfiguration().getAccessKey());
- assertEquals("yyyyy", endpoint.getConfiguration().getSecretKey());
- assertEquals("US_EAST_1", endpoint.getConfiguration().getRegion());
- }
-
- @Test
- public void createEndpointWithComponentEndpointElementsAndProxy() throws Exception {
- EKSComponent component = context.getComponent("aws-eks", EKSComponent.class);
- component.getConfiguration().setAccessKey("XXX");
- component.getConfiguration().setSecretKey("YYY");
- component.getConfiguration().setRegion(Regions.US_WEST_1.toString());
- EKSEndpoint endpoint = (EKSEndpoint) component.createEndpoint(
- "aws-eks://label?accessKey=xxxxxx&secretKey=yyyyy®ion=US_EAST_1&proxyHost=localhost&proxyPort=9000&proxyProtocol=HTTP");
-
- assertEquals("xxxxxx", endpoint.getConfiguration().getAccessKey());
- assertEquals("yyyyy", endpoint.getConfiguration().getSecretKey());
- assertEquals("US_EAST_1", endpoint.getConfiguration().getRegion());
- assertEquals(Protocol.HTTP, endpoint.getConfiguration().getProxyProtocol());
- assertEquals("localhost", endpoint.getConfiguration().getProxyHost());
- assertEquals(Integer.valueOf(9000), endpoint.getConfiguration().getProxyPort());
- }
-}
diff --git a/components/camel-aws-eks/src/test/java/org/apache/camel/component/aws/eks/EKSComponentVerifierExtensionTest.java b/components/camel-aws-eks/src/test/java/org/apache/camel/component/aws/eks/EKSComponentVerifierExtensionTest.java
deleted file mode 100644
index 8f318a8..0000000
--- a/components/camel-aws-eks/src/test/java/org/apache/camel/component/aws/eks/EKSComponentVerifierExtensionTest.java
+++ /dev/null
@@ -1,76 +0,0 @@
-/*
- * 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.component.aws.eks;
-
-import java.util.HashMap;
-import java.util.Map;
-
-import org.apache.camel.Component;
-import org.apache.camel.component.extension.ComponentVerifierExtension;
-import org.apache.camel.test.junit5.CamelTestSupport;
-import org.junit.jupiter.api.Test;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-
-public class EKSComponentVerifierExtensionTest extends CamelTestSupport {
-
- // *************************************************
- // Tests (parameters)
- // *************************************************
- @Override
- public boolean isUseRouteBuilder() {
- return false;
- }
-
- @Test
- public void testParameters() throws Exception {
- Component component = context().getComponent("aws-eks");
-
- ComponentVerifierExtension verifier
- = component.getExtension(ComponentVerifierExtension.class).orElseThrow(IllegalStateException::new);
-
- Map<String, Object> parameters = new HashMap<>();
- parameters.put("secretKey", "l");
- parameters.put("accessKey", "k");
- parameters.put("region", "l");
- parameters.put("label", "test");
- parameters.put("operation", EKSOperations.listClusters);
-
- ComponentVerifierExtension.Result result = verifier.verify(ComponentVerifierExtension.Scope.PARAMETERS, parameters);
-
- assertEquals(ComponentVerifierExtension.Result.Status.OK, result.getStatus());
- }
-
- @Test
- public void testConnectivity() throws Exception {
- Component component = context().getComponent("aws-eks");
- ComponentVerifierExtension verifier
- = component.getExtension(ComponentVerifierExtension.class).orElseThrow(IllegalStateException::new);
-
- Map<String, Object> parameters = new HashMap<>();
- parameters.put("secretKey", "l");
- parameters.put("accessKey", "k");
- parameters.put("region", "US_EAST_1");
- parameters.put("label", "test");
- parameters.put("operation", EKSOperations.listClusters);
-
- ComponentVerifierExtension.Result result = verifier.verify(ComponentVerifierExtension.Scope.CONNECTIVITY, parameters);
-
- assertEquals(ComponentVerifierExtension.Result.Status.ERROR, result.getStatus());
- }
-
-}
diff --git a/components/camel-aws-eks/src/test/java/org/apache/camel/component/aws/eks/EKSProducerSpringTest.java b/components/camel-aws-eks/src/test/java/org/apache/camel/component/aws/eks/EKSProducerSpringTest.java
deleted file mode 100644
index 3a0c815..0000000
--- a/components/camel-aws-eks/src/test/java/org/apache/camel/component/aws/eks/EKSProducerSpringTest.java
+++ /dev/null
@@ -1,118 +0,0 @@
-/*
- * 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.component.aws.eks;
-
-import com.amazonaws.services.eks.model.CreateClusterResult;
-import com.amazonaws.services.eks.model.DeleteClusterResult;
-import com.amazonaws.services.eks.model.DescribeClusterResult;
-import com.amazonaws.services.eks.model.ListClustersResult;
-import com.amazonaws.services.eks.model.VpcConfigRequest;
-import org.apache.camel.EndpointInject;
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.test.spring.junit5.CamelSpringTestSupport;
-import org.junit.jupiter.api.Test;
-import org.springframework.context.support.ClassPathXmlApplicationContext;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-
-public class EKSProducerSpringTest extends CamelSpringTestSupport {
-
- @EndpointInject("mock:result")
- private MockEndpoint mock;
-
- @Test
- public void kmsListClustersTest() throws Exception {
-
- mock.expectedMessageCount(1);
- Exchange exchange = template.request("direct:listClusters", new Processor() {
- @Override
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(EKSConstants.OPERATION, EKSOperations.listClusters);
- }
- });
-
- assertMockEndpointsSatisfied();
-
- ListClustersResult resultGet = (ListClustersResult) exchange.getIn().getBody();
- assertEquals(1, resultGet.getClusters().size());
- assertEquals("Test", resultGet.getClusters().get(0));
- }
-
- @Test
- public void eksCreateClusterTest() throws Exception {
-
- mock.expectedMessageCount(1);
- Exchange exchange = template.request("direct:createCluster", new Processor() {
- @Override
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(EKSConstants.OPERATION, EKSOperations.createCluster);
- exchange.getIn().setHeader(EKSConstants.CLUSTER_NAME, "Test");
- VpcConfigRequest req = new VpcConfigRequest();
- exchange.getIn().setHeader(EKSConstants.VPC_CONFIG, req);
- exchange.getIn().setHeader(EKSConstants.ROLE_ARN, "arn:aws:eks::123456789012:user/Camel");
- }
- });
-
- assertMockEndpointsSatisfied();
-
- CreateClusterResult resultGet = (CreateClusterResult) exchange.getIn().getBody();
- assertEquals("Test", resultGet.getCluster().getName());
- }
-
- @Test
- public void eksDescribeClusterTest() throws Exception {
-
- mock.expectedMessageCount(1);
- Exchange exchange = template.request("direct:describeCluster", new Processor() {
- @Override
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(EKSConstants.OPERATION, EKSOperations.describeCluster);
- exchange.getIn().setHeader(EKSConstants.CLUSTER_NAME, "Test");
- }
- });
-
- assertMockEndpointsSatisfied();
-
- DescribeClusterResult resultGet = exchange.getIn().getBody(DescribeClusterResult.class);
- assertEquals("Test", resultGet.getCluster().getName());
- }
-
- @Test
- public void eksDeleteClusterTest() throws Exception {
-
- mock.expectedMessageCount(1);
- Exchange exchange = template.request("direct:deleteCluster", new Processor() {
- @Override
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(EKSConstants.OPERATION, EKSOperations.deleteCluster);
- exchange.getIn().setHeader(EKSConstants.CLUSTER_NAME, "Test");
- }
- });
-
- assertMockEndpointsSatisfied();
-
- DeleteClusterResult resultGet = exchange.getIn().getBody(DeleteClusterResult.class);
- assertEquals("Test", resultGet.getCluster().getName());
- }
-
- @Override
- protected ClassPathXmlApplicationContext createApplicationContext() {
- return new ClassPathXmlApplicationContext("org/apache/camel/component/aws/eks/EKSComponentSpringTest-context.xml");
- }
-}
diff --git a/components/camel-aws-eks/src/test/java/org/apache/camel/component/aws/eks/EKSProducerTest.java b/components/camel-aws-eks/src/test/java/org/apache/camel/component/aws/eks/EKSProducerTest.java
deleted file mode 100644
index dd24c9b..0000000
--- a/components/camel-aws-eks/src/test/java/org/apache/camel/component/aws/eks/EKSProducerTest.java
+++ /dev/null
@@ -1,138 +0,0 @@
-/*
- * 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.component.aws.eks;
-
-import com.amazonaws.services.eks.model.CreateClusterResult;
-import com.amazonaws.services.eks.model.DeleteClusterResult;
-import com.amazonaws.services.eks.model.DescribeClusterResult;
-import com.amazonaws.services.eks.model.ListClustersResult;
-import com.amazonaws.services.eks.model.VpcConfigRequest;
-import org.apache.camel.BindToRegistry;
-import org.apache.camel.EndpointInject;
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.test.junit5.CamelTestSupport;
-import org.junit.jupiter.api.Test;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-
-public class EKSProducerTest extends CamelTestSupport {
-
- @BindToRegistry("amazonEksClient")
- AmazonEKSClientMock clientMock = new AmazonEKSClientMock();
-
- @EndpointInject("mock:result")
- private MockEndpoint mock;
-
- @Test
- public void kmsListClustersTest() throws Exception {
-
- mock.expectedMessageCount(1);
- Exchange exchange = template.request("direct:listClusters", new Processor() {
- @Override
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(EKSConstants.OPERATION, EKSOperations.listClusters);
- }
- });
-
- assertMockEndpointsSatisfied();
-
- ListClustersResult resultGet = (ListClustersResult) exchange.getIn().getBody();
- assertEquals(1, resultGet.getClusters().size());
- assertEquals("Test", resultGet.getClusters().get(0));
- }
-
- @Test
- public void eksCreateClusterTest() throws Exception {
-
- mock.expectedMessageCount(1);
- Exchange exchange = template.request("direct:createCluster", new Processor() {
- @Override
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(EKSConstants.OPERATION, EKSOperations.createCluster);
- exchange.getIn().setHeader(EKSConstants.CLUSTER_NAME, "Test");
- VpcConfigRequest req = new VpcConfigRequest();
- exchange.getIn().setHeader(EKSConstants.VPC_CONFIG, req);
- exchange.getIn().setHeader(EKSConstants.ROLE_ARN, "arn:aws:eks::123456789012:user/Camel");
- }
- });
-
- assertMockEndpointsSatisfied();
-
- CreateClusterResult resultGet = (CreateClusterResult) exchange.getIn().getBody();
- assertEquals("Test", resultGet.getCluster().getName());
- }
-
- @Test
- public void eksDescribeClusterTest() throws Exception {
-
- mock.expectedMessageCount(1);
- Exchange exchange = template.request("direct:describeCluster", new Processor() {
- @Override
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(EKSConstants.OPERATION, EKSOperations.describeCluster);
- exchange.getIn().setHeader(EKSConstants.CLUSTER_NAME, "Test");
- }
- });
-
- assertMockEndpointsSatisfied();
-
- DescribeClusterResult resultGet = exchange.getIn().getBody(DescribeClusterResult.class);
- assertEquals("Test", resultGet.getCluster().getName());
- }
-
- @Test
- public void eksDeleteClusterTest() throws Exception {
-
- mock.expectedMessageCount(1);
- Exchange exchange = template.request("direct:deleteCluster", new Processor() {
- @Override
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(EKSConstants.OPERATION, EKSOperations.deleteCluster);
- exchange.getIn().setHeader(EKSConstants.CLUSTER_NAME, "Test");
- }
- });
-
- assertMockEndpointsSatisfied();
-
- DeleteClusterResult resultGet = exchange.getIn().getBody(DeleteClusterResult.class);
- assertEquals("Test", resultGet.getCluster().getName());
- }
-
- @Override
- protected RouteBuilder createRouteBuilder() throws Exception {
- return new RouteBuilder() {
- @Override
- public void configure() throws Exception {
- from("direct:listClusters")
- .to("aws-eks://test?eksClient=#amazonEksClient&operation=listClusters")
- .to("mock:result");
- from("direct:createCluster")
- .to("aws-eks://test?eksClient=#amazonEksClient&operation=createCluster")
- .to("mock:result");
- from("direct:deleteCluster")
- .to("aws-eks://test?eksClient=#amazonEksClient&operation=deleteCluster")
- .to("mock:result");
- from("direct:describeCluster")
- .to("aws-eks://test?eksClient=#amazonEksClient&operation=describeCluster")
- .to("mock:result");
- }
- };
- }
-}
diff --git a/components/camel-aws-eks/src/test/resources/log4j2.properties b/components/camel-aws-eks/src/test/resources/log4j2.properties
deleted file mode 100644
index bd64fd3..0000000
--- a/components/camel-aws-eks/src/test/resources/log4j2.properties
+++ /dev/null
@@ -1,28 +0,0 @@
-## ---------------------------------------------------------------------------
-## 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.
-## ---------------------------------------------------------------------------
-
-appender.file.type = File
-appender.file.name = file
-appender.file.fileName = target/camel-aws-eks-test.log
-appender.file.layout.type = PatternLayout
-appender.file.layout.pattern = %d [%-15.15t] %-5p %-30.30c{1} - %m%n
-appender.out.type = Console
-appender.out.name = out
-appender.out.layout.type = PatternLayout
-appender.out.layout.pattern = %d [%-15.15t] %-5p %-30.30c{1} - %m%n
-rootLogger.level = INFO
-rootLogger.appenderRef.file.ref = file
diff --git a/components/camel-aws-eks/src/test/resources/org/apache/camel/component/aws/eks/EKSComponentSpringTest-context.xml b/components/camel-aws-eks/src/test/resources/org/apache/camel/component/aws/eks/EKSComponentSpringTest-context.xml
deleted file mode 100644
index 2b17b83..0000000
--- a/components/camel-aws-eks/src/test/resources/org/apache/camel/component/aws/eks/EKSComponentSpringTest-context.xml
+++ /dev/null
@@ -1,50 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
-
- Licensed to the Apache Software Foundation (ASF) under one or more
- contributor license agreements. See the NOTICE file distributed with
- this work for additional information regarding copyright ownership.
- The ASF licenses this file to You under the Apache License, Version 2.0
- (the "License"); you may not use this file except in compliance with
- the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
-
--->
-<beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="
- http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
- http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">
-
- <camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">
- <route>
- <from uri="direct:listClusters"/>
- <to uri="aws-eks://test?eksClient=#amazonEksClient&operation=listClusters"/>
- <to uri="mock:result"/>
- </route>
- <route>
- <from uri="direct:createCluster"/>
- <to uri="aws-eks://test?eksClient=#amazonEksClient&operation=createCluster"/>
- <to uri="mock:result"/>
- </route>
- <route>
- <from uri="direct:deleteCluster"/>
- <to uri="aws-eks://test?eksClient=#amazonEksClient&operation=deleteCluster"/>
- <to uri="mock:result"/>
- </route>
- <route>
- <from uri="direct:describeCluster"/>
- <to uri="aws-eks://test?eksClient=#amazonEksClient&operation=describeCluster"/>
- <to uri="mock:result"/>
- </route>
- </camelContext>
-
- <bean id="amazonEksClient" class="org.apache.camel.component.aws.eks.AmazonEKSClientMock"/>
-</beans>
\ No newline at end of file
diff --git a/components/pom.xml b/components/pom.xml
index 8a3c9e9..321fdd2 100644
--- a/components/pom.xml
+++ b/components/pom.xml
@@ -111,7 +111,6 @@
<module>camel-aws-ddb</module>
<module>camel-aws-ec2</module>
<module>camel-aws-ecs</module>
- <module>camel-aws-eks</module>
<module>camel-aws-s3</module>
<module>camel-aws-swf</module>
<module>camel-aws2-athena</module>
[camel] 05/05: CAMEL-16115 - Remove Camel-AWS-* components - AWS-EKS
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 3d39afd7d8c65b55cc2ad8ddd6aa1f64fcf02e4e
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Feb 23 08:44:10 2021 +0100
CAMEL-16115 - Remove Camel-AWS-* components - AWS-EKS
---
docs/user-manual/modules/ROOT/pages/camel-3x-upgrade-guide-3_9.adoc | 1 +
1 file changed, 1 insertion(+)
diff --git a/docs/user-manual/modules/ROOT/pages/camel-3x-upgrade-guide-3_9.adoc b/docs/user-manual/modules/ROOT/pages/camel-3x-upgrade-guide-3_9.adoc
index b531bdd..bb94df6 100644
--- a/docs/user-manual/modules/ROOT/pages/camel-3x-upgrade-guide-3_9.adoc
+++ b/docs/user-manual/modules/ROOT/pages/camel-3x-upgrade-guide-3_9.adoc
@@ -51,3 +51,4 @@ the one to use above, and then add which -starter JARs you want to use in your C
- Camel-AWS-Kinesis has been removed. Please switch to Camel-AWS2-Kinesis.
- Camel-AWS-Kinesis Firehose has been removed. Please switch to Camel-AWS2-Kinesis-firehose.
- Camel-AWS-IAM has been removed. Please switch to Camel-AWS2-IAM.
+- Camel-AWS-EKS has been removed. Please switch to Camel-AWS2-EKS.
[camel] 02/05: CAMEL-16115 - Remove Camel-AWS-* components - AWS-EKS
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit f9ed0c3789d12c9824c24edb9208a200da1fbbb6
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Feb 23 08:28:55 2021 +0100
CAMEL-16115 - Remove Camel-AWS-* components - AWS-EKS
---
bom/camel-bom/pom.xml | 5 -----
core/camel-allcomponents/pom.xml | 4 ----
parent/pom.xml | 5 -----
3 files changed, 14 deletions(-)
diff --git a/bom/camel-bom/pom.xml b/bom/camel-bom/pom.xml
index 16215de..3edfc13 100644
--- a/bom/camel-bom/pom.xml
+++ b/bom/camel-bom/pom.xml
@@ -158,11 +158,6 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
- <artifactId>camel-aws-eks</artifactId>
- <version>${project.version}</version>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
<artifactId>camel-aws-s3</artifactId>
<version>${project.version}</version>
</dependency>
diff --git a/core/camel-allcomponents/pom.xml b/core/camel-allcomponents/pom.xml
index 1daf4ec..90aae48 100644
--- a/core/camel-allcomponents/pom.xml
+++ b/core/camel-allcomponents/pom.xml
@@ -127,10 +127,6 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
- <artifactId>camel-aws-eks</artifactId>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
<artifactId>camel-aws-s3</artifactId>
</dependency>
<dependency>
diff --git a/parent/pom.xml b/parent/pom.xml
index 33f9312..2056b54 100644
--- a/parent/pom.xml
+++ b/parent/pom.xml
@@ -878,11 +878,6 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
- <artifactId>camel-aws-eks</artifactId>
- <version>${project.version}</version>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
<artifactId>camel-aws-s3</artifactId>
<version>${project.version}</version>
</dependency>
[camel] 03/05: CAMEL-16115 - Remove Camel-AWS-* components - AWS-EKS
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 9f8f549f11f2e2097fbaba3e76a5379f55222cc4
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Feb 23 08:30:00 2021 +0100
CAMEL-16115 - Remove Camel-AWS-* components - AWS-EKS
---
.../component/ComponentsBuilderFactory.java | 16 +-
.../dsl/AwsEksComponentBuilderFactory.java | 292 ----------------
.../builder/endpoint/StaticEndpointBuilders.java | 47 +--
.../endpoint/dsl/EKSEndpointBuilderFactory.java | 376 ---------------------
4 files changed, 2 insertions(+), 729 deletions(-)
diff --git a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java
index a99abbb..4bb7c63 100644
--- a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java
+++ b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java
@@ -376,20 +376,6 @@ public interface ComponentsBuilderFactory {
return org.apache.camel.builder.component.dsl.AwsEcsComponentBuilderFactory.awsEcs();
}
/**
- * AWS Elastic Kubernetes Service (EKS) (camel-aws-eks)
- * Manage AWS EKS cluster instances.
- *
- * Category: cloud,management
- * Since: 3.0
- * Maven coordinates: org.apache.camel:camel-aws-eks
- *
- * @return the dsl builder
- */
- @Deprecated
- static org.apache.camel.builder.component.dsl.AwsEksComponentBuilderFactory.AwsEksComponentBuilder awsEks() {
- return org.apache.camel.builder.component.dsl.AwsEksComponentBuilderFactory.awsEks();
- }
- /**
* AWS S3 Storage Service (camel-aws-s3)
* Store and retrieve objects from AWS S3 Storage Service.
*
@@ -4778,4 +4764,4 @@ public interface ComponentsBuilderFactory {
static org.apache.camel.builder.component.dsl.ZookeeperMasterComponentBuilderFactory.ZookeeperMasterComponentBuilder zookeeperMaster() {
return org.apache.camel.builder.component.dsl.ZookeeperMasterComponentBuilderFactory.zookeeperMaster();
}
-}
\ No newline at end of file
+}
diff --git a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsEksComponentBuilderFactory.java b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsEksComponentBuilderFactory.java
deleted file mode 100644
index 30ba23c..0000000
--- a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsEksComponentBuilderFactory.java
+++ /dev/null
@@ -1,292 +0,0 @@
-/*
- * 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.aws.eks.EKSComponent;
-
-/**
- * Manage AWS EKS cluster instances.
- *
- * Generated by camel-package-maven-plugin - do not edit this file!
- */
-@Generated("org.apache.camel.maven.packaging.ComponentDslMojo")
-public interface AwsEksComponentBuilderFactory {
-
- /**
- * AWS Elastic Kubernetes Service (EKS) (camel-aws-eks)
- * Manage AWS EKS cluster instances.
- *
- * Category: cloud,management
- * Since: 3.0
- * Maven coordinates: org.apache.camel:camel-aws-eks
- *
- * @return the dsl builder
- */
- @Deprecated
- static AwsEksComponentBuilder awsEks() {
- return new AwsEksComponentBuilderImpl();
- }
-
- /**
- * Builder for the AWS Elastic Kubernetes Service (EKS) component.
- */
- interface AwsEksComponentBuilder extends ComponentBuilder<EKSComponent> {
- /**
- * Setting the autoDiscoverClient mechanism, if true, the component will
- * look for a client instance in the registry automatically otherwise it
- * will skip that checking.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: true
- * Group: common
- *
- * @param autoDiscoverClient the value to set
- * @return the dsl builder
- */
- default AwsEksComponentBuilder autoDiscoverClient(
- boolean autoDiscoverClient) {
- doSetProperty("autoDiscoverClient", autoDiscoverClient);
- return this;
- }
- /**
- * Amazon AWS Access Key.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: producer
- *
- * @param accessKey the value to set
- * @return the dsl builder
- */
- default AwsEksComponentBuilder accessKey(java.lang.String accessKey) {
- doSetProperty("accessKey", accessKey);
- return this;
- }
- /**
- * The component configuration.
- *
- * The option is a:
- * <code>org.apache.camel.component.aws.eks.EKSConfiguration</code> type.
- *
- * Group: producer
- *
- * @param configuration the value to set
- * @return the dsl builder
- */
- default AwsEksComponentBuilder configuration(
- org.apache.camel.component.aws.eks.EKSConfiguration configuration) {
- doSetProperty("configuration", configuration);
- return this;
- }
- /**
- * To use a existing configured AWS EKS as client.
- *
- * The option is a:
- * <code>com.amazonaws.services.eks.AmazonEKS</code> type.
- *
- * Group: producer
- *
- * @param eksClient the value to set
- * @return the dsl builder
- */
- default AwsEksComponentBuilder eksClient(
- com.amazonaws.services.eks.AmazonEKS eksClient) {
- doSetProperty("eksClient", eksClient);
- 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 AwsEksComponentBuilder lazyStartProducer(
- boolean lazyStartProducer) {
- doSetProperty("lazyStartProducer", lazyStartProducer);
- return this;
- }
- /**
- * The operation to perform.
- *
- * The option is a:
- * <code>org.apache.camel.component.aws.eks.EKSOperations</code> type.
- *
- * Group: producer
- *
- * @param operation the value to set
- * @return the dsl builder
- */
- default AwsEksComponentBuilder operation(
- org.apache.camel.component.aws.eks.EKSOperations operation) {
- doSetProperty("operation", operation);
- return this;
- }
- /**
- * To define a proxy host when instantiating the EKS client.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: producer
- *
- * @param proxyHost the value to set
- * @return the dsl builder
- */
- default AwsEksComponentBuilder proxyHost(java.lang.String proxyHost) {
- doSetProperty("proxyHost", proxyHost);
- return this;
- }
- /**
- * To define a proxy port when instantiating the EKS client.
- *
- * The option is a: <code>java.lang.Integer</code> type.
- *
- * Group: producer
- *
- * @param proxyPort the value to set
- * @return the dsl builder
- */
- default AwsEksComponentBuilder proxyPort(java.lang.Integer proxyPort) {
- doSetProperty("proxyPort", proxyPort);
- return this;
- }
- /**
- * To define a proxy protocol when instantiating the EKS client.
- *
- * The option is a: <code>com.amazonaws.Protocol</code>
- * type.
- *
- * Default: HTTPS
- * Group: producer
- *
- * @param proxyProtocol the value to set
- * @return the dsl builder
- */
- default AwsEksComponentBuilder proxyProtocol(
- com.amazonaws.Protocol proxyProtocol) {
- doSetProperty("proxyProtocol", proxyProtocol);
- return this;
- }
- /**
- * The region in which EKS client needs to work. When using this
- * parameter, the configuration will expect the capitalized name of the
- * region (for example AP_EAST_1) You'll need to use the name
- * Regions.EU_WEST_1.name().
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: producer
- *
- * @param region the value to set
- * @return the dsl builder
- */
- default AwsEksComponentBuilder region(java.lang.String region) {
- doSetProperty("region", region);
- return this;
- }
- /**
- * Amazon AWS Secret Key.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: producer
- *
- * @param secretKey the value to set
- * @return the dsl builder
- */
- default AwsEksComponentBuilder secretKey(java.lang.String secretKey) {
- doSetProperty("secretKey", secretKey);
- 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 AwsEksComponentBuilder autowiredEnabled(boolean autowiredEnabled) {
- doSetProperty("autowiredEnabled", autowiredEnabled);
- return this;
- }
- }
-
- class AwsEksComponentBuilderImpl
- extends
- AbstractComponentBuilder<EKSComponent>
- implements
- AwsEksComponentBuilder {
- @Override
- protected EKSComponent buildConcreteComponent() {
- return new EKSComponent();
- }
- private org.apache.camel.component.aws.eks.EKSConfiguration getOrCreateConfiguration(
- org.apache.camel.component.aws.eks.EKSComponent component) {
- if (component.getConfiguration() == null) {
- component.setConfiguration(new org.apache.camel.component.aws.eks.EKSConfiguration());
- }
- return component.getConfiguration();
- }
- @Override
- protected boolean setPropertyOnComponent(
- Component component,
- String name,
- Object value) {
- switch (name) {
- case "autoDiscoverClient": getOrCreateConfiguration((EKSComponent) component).setAutoDiscoverClient((boolean) value); return true;
- case "accessKey": getOrCreateConfiguration((EKSComponent) component).setAccessKey((java.lang.String) value); return true;
- case "configuration": ((EKSComponent) component).setConfiguration((org.apache.camel.component.aws.eks.EKSConfiguration) value); return true;
- case "eksClient": getOrCreateConfiguration((EKSComponent) component).setEksClient((com.amazonaws.services.eks.AmazonEKS) value); return true;
- case "lazyStartProducer": ((EKSComponent) component).setLazyStartProducer((boolean) value); return true;
- case "operation": getOrCreateConfiguration((EKSComponent) component).setOperation((org.apache.camel.component.aws.eks.EKSOperations) value); return true;
- case "proxyHost": getOrCreateConfiguration((EKSComponent) component).setProxyHost((java.lang.String) value); return true;
- case "proxyPort": getOrCreateConfiguration((EKSComponent) component).setProxyPort((java.lang.Integer) value); return true;
- case "proxyProtocol": getOrCreateConfiguration((EKSComponent) component).setProxyProtocol((com.amazonaws.Protocol) value); return true;
- case "region": getOrCreateConfiguration((EKSComponent) component).setRegion((java.lang.String) value); return true;
- case "secretKey": getOrCreateConfiguration((EKSComponent) component).setSecretKey((java.lang.String) value); return true;
- case "autowiredEnabled": ((EKSComponent) component).setAutowiredEnabled((boolean) value); return true;
- default: return false;
- }
- }
- }
-}
\ No newline at end of file
diff --git a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
index f3ddee9..ab1f063 100644
--- a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
+++ b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
@@ -2057,51 +2057,6 @@ public class StaticEndpointBuilders {
return org.apache.camel.builder.endpoint.dsl.ECSEndpointBuilderFactory.endpointBuilder(componentName, path);
}
/**
- * AWS Elastic Kubernetes Service (EKS) (camel-aws-eks)
- * Manage AWS EKS cluster instances.
- *
- * Category: cloud,management
- * Since: 3.0
- * Maven coordinates: org.apache.camel:camel-aws-eks
- *
- * Syntax: <code>aws-eks:label</code>
- *
- * Path parameter: label (required)
- * Logical name
- *
- * @param path label
- * @return the dsl builder
- */
- @Deprecated
- public static org.apache.camel.builder.endpoint.dsl.EKSEndpointBuilderFactory.EKSEndpointBuilder awsEks(
- String path) {
- return org.apache.camel.builder.endpoint.dsl.EKSEndpointBuilderFactory.endpointBuilder("aws-eks", path);
- }
- /**
- * AWS Elastic Kubernetes Service (EKS) (camel-aws-eks)
- * Manage AWS EKS cluster instances.
- *
- * Category: cloud,management
- * Since: 3.0
- * Maven coordinates: org.apache.camel:camel-aws-eks
- *
- * Syntax: <code>aws-eks:label</code>
- *
- * Path parameter: label (required)
- * Logical name
- *
- * @param componentName to use a custom component name for the endpoint
- * instead of the default name
- * @param path label
- * @return the dsl builder
- */
- @Deprecated
- public static org.apache.camel.builder.endpoint.dsl.EKSEndpointBuilderFactory.EKSEndpointBuilder awsEks(
- String componentName,
- String path) {
- return org.apache.camel.builder.endpoint.dsl.EKSEndpointBuilderFactory.endpointBuilder(componentName, path);
- }
- /**
* AWS S3 Storage Service (camel-aws-s3)
* Store and retrieve objects from AWS S3 Storage Service.
*
@@ -16757,4 +16712,4 @@ public class StaticEndpointBuilders {
return org.apache.camel.builder.endpoint.dsl.ZooKeeperMasterEndpointBuilderFactory.endpointBuilder(componentName, path);
}
}
-//CHECKSTYLE:ON
\ No newline at end of file
+//CHECKSTYLE:ON
diff --git a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/EKSEndpointBuilderFactory.java b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/EKSEndpointBuilderFactory.java
deleted file mode 100644
index edd8c56f..0000000
--- a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/EKSEndpointBuilderFactory.java
+++ /dev/null
@@ -1,376 +0,0 @@
-/*
- * 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 javax.annotation.Generated;
-import org.apache.camel.builder.EndpointConsumerBuilder;
-import org.apache.camel.builder.EndpointProducerBuilder;
-import org.apache.camel.builder.endpoint.AbstractEndpointBuilder;
-
-/**
- * Manage AWS EKS cluster instances.
- *
- * Generated by camel build tools - do NOT edit this file!
- */
-@Generated("org.apache.camel.maven.packaging.EndpointDslMojo")
-public interface EKSEndpointBuilderFactory {
-
-
- /**
- * Builder for endpoint for the AWS Elastic Kubernetes Service (EKS)
- * component.
- */
- public interface EKSEndpointBuilder extends EndpointProducerBuilder {
- /**
- * Setting the autoDiscoverClient mechanism, if true, the component will
- * look for a client instance in the registry automatically otherwise it
- * will skip that checking.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: true
- * Group: common
- *
- * @param autoDiscoverClient the value to set
- * @return the dsl builder
- */
- default EKSEndpointBuilder autoDiscoverClient(boolean autoDiscoverClient) {
- doSetProperty("autoDiscoverClient", autoDiscoverClient);
- return this;
- }
- /**
- * Setting the autoDiscoverClient mechanism, if true, the component will
- * look for a client instance in the registry automatically otherwise it
- * will skip that checking.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: true
- * Group: common
- *
- * @param autoDiscoverClient the value to set
- * @return the dsl builder
- */
- default EKSEndpointBuilder autoDiscoverClient(String autoDiscoverClient) {
- doSetProperty("autoDiscoverClient", autoDiscoverClient);
- return this;
- }
- /**
- * Amazon AWS Access Key.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: producer
- *
- * @param accessKey the value to set
- * @return the dsl builder
- */
- default EKSEndpointBuilder accessKey(String accessKey) {
- doSetProperty("accessKey", accessKey);
- return this;
- }
- /**
- * To use a existing configured AWS EKS as client.
- *
- * The option is a:
- * <code>com.amazonaws.services.eks.AmazonEKS</code> type.
- *
- * Group: producer
- *
- * @param eksClient the value to set
- * @return the dsl builder
- */
- default EKSEndpointBuilder eksClient(Object eksClient) {
- doSetProperty("eksClient", eksClient);
- return this;
- }
- /**
- * To use a existing configured AWS EKS as client.
- *
- * The option will be converted to a
- * <code>com.amazonaws.services.eks.AmazonEKS</code> type.
- *
- * Group: producer
- *
- * @param eksClient the value to set
- * @return the dsl builder
- */
- default EKSEndpointBuilder eksClient(String eksClient) {
- doSetProperty("eksClient", eksClient);
- 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 EKSEndpointBuilder 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
- *
- * @param lazyStartProducer the value to set
- * @return the dsl builder
- */
- default EKSEndpointBuilder lazyStartProducer(String lazyStartProducer) {
- doSetProperty("lazyStartProducer", lazyStartProducer);
- return this;
- }
- /**
- * The operation to perform.
- *
- * The option is a:
- * <code>org.apache.camel.component.aws.eks.EKSOperations</code> type.
- *
- * Required: true
- * Group: producer
- *
- * @param operation the value to set
- * @return the dsl builder
- */
- default EKSEndpointBuilder operation(EKSOperations operation) {
- doSetProperty("operation", operation);
- return this;
- }
- /**
- * The operation to perform.
- *
- * The option will be converted to a
- * <code>org.apache.camel.component.aws.eks.EKSOperations</code> type.
- *
- * Required: true
- * Group: producer
- *
- * @param operation the value to set
- * @return the dsl builder
- */
- default EKSEndpointBuilder operation(String operation) {
- doSetProperty("operation", operation);
- return this;
- }
- /**
- * To define a proxy host when instantiating the EKS client.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: producer
- *
- * @param proxyHost the value to set
- * @return the dsl builder
- */
- default EKSEndpointBuilder proxyHost(String proxyHost) {
- doSetProperty("proxyHost", proxyHost);
- return this;
- }
- /**
- * To define a proxy port when instantiating the EKS client.
- *
- * The option is a: <code>java.lang.Integer</code> type.
- *
- * Group: producer
- *
- * @param proxyPort the value to set
- * @return the dsl builder
- */
- default EKSEndpointBuilder proxyPort(Integer proxyPort) {
- doSetProperty("proxyPort", proxyPort);
- return this;
- }
- /**
- * To define a proxy port when instantiating the EKS client.
- *
- * The option will be converted to a
- * <code>java.lang.Integer</code> type.
- *
- * Group: producer
- *
- * @param proxyPort the value to set
- * @return the dsl builder
- */
- default EKSEndpointBuilder proxyPort(String proxyPort) {
- doSetProperty("proxyPort", proxyPort);
- return this;
- }
- /**
- * To define a proxy protocol when instantiating the EKS client.
- *
- * The option is a: <code>com.amazonaws.Protocol</code>
- * type.
- *
- * Default: HTTPS
- * Group: producer
- *
- * @param proxyProtocol the value to set
- * @return the dsl builder
- */
- default EKSEndpointBuilder proxyProtocol(Protocol proxyProtocol) {
- doSetProperty("proxyProtocol", proxyProtocol);
- return this;
- }
- /**
- * To define a proxy protocol when instantiating the EKS client.
- *
- * The option will be converted to a
- * <code>com.amazonaws.Protocol</code> type.
- *
- * Default: HTTPS
- * Group: producer
- *
- * @param proxyProtocol the value to set
- * @return the dsl builder
- */
- default EKSEndpointBuilder proxyProtocol(String proxyProtocol) {
- doSetProperty("proxyProtocol", proxyProtocol);
- return this;
- }
- /**
- * The region in which EKS client needs to work. When using this
- * parameter, the configuration will expect the capitalized name of the
- * region (for example AP_EAST_1) You'll need to use the name
- * Regions.EU_WEST_1.name().
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: producer
- *
- * @param region the value to set
- * @return the dsl builder
- */
- default EKSEndpointBuilder region(String region) {
- doSetProperty("region", region);
- return this;
- }
- /**
- * Amazon AWS Secret Key.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: producer
- *
- * @param secretKey the value to set
- * @return the dsl builder
- */
- default EKSEndpointBuilder secretKey(String secretKey) {
- doSetProperty("secretKey", secretKey);
- return this;
- }
- }
-
- /**
- * Proxy enum for
- * <code>org.apache.camel.component.aws.eks.EKSOperations</code> enum.
- */
- enum EKSOperations {
- listClusters,
- describeCluster,
- createCluster,
- deleteCluster;
- }
-
- /**
- * Proxy enum for <code>com.amazonaws.Protocol</code> enum.
- */
- enum Protocol {
- HTTP,
- HTTPS;
- }
-
- public interface EKSBuilders {
- /**
- * AWS Elastic Kubernetes Service (EKS) (camel-aws-eks)
- * Manage AWS EKS cluster instances.
- *
- * Category: cloud,management
- * Since: 3.0
- * Maven coordinates: org.apache.camel:camel-aws-eks
- *
- * Syntax: <code>aws-eks:label</code>
- *
- * Path parameter: label (required)
- * Logical name
- *
- * @param path label
- * @return the dsl builder
- */
- @Deprecated
- default EKSEndpointBuilder awsEks(String path) {
- return EKSEndpointBuilderFactory.endpointBuilder("aws-eks", path);
- }
- /**
- * AWS Elastic Kubernetes Service (EKS) (camel-aws-eks)
- * Manage AWS EKS cluster instances.
- *
- * Category: cloud,management
- * Since: 3.0
- * Maven coordinates: org.apache.camel:camel-aws-eks
- *
- * Syntax: <code>aws-eks:label</code>
- *
- * Path parameter: label (required)
- * Logical name
- *
- * @param componentName to use a custom component name for the endpoint
- * instead of the default name
- * @param path label
- * @return the dsl builder
- */
- @Deprecated
- default EKSEndpointBuilder awsEks(String componentName, String path) {
- return EKSEndpointBuilderFactory.endpointBuilder(componentName, path);
- }
- }
- @Deprecated
- static EKSEndpointBuilder endpointBuilder(String componentName, String path) {
- class EKSEndpointBuilderImpl extends AbstractEndpointBuilder implements EKSEndpointBuilder {
- public EKSEndpointBuilderImpl(String path) {
- super(componentName, path);
- }
- }
- return new EKSEndpointBuilderImpl(path);
- }
-}
\ No newline at end of file