aws-* kamelets: expose delay parameter where possible

kamelets/aws-ddb-streams-source.kamelet.yaml

@@ -89,6 +89,11 @@ spec:
         x-descriptors:
           - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
         default: false
+      delay:
+        title: Delay
+        description: Milliseconds before the next poll from database
+        type: long
+        default: 500
   types:
     out:
       mediaType: application/json
@@ -107,6 +112,7 @@ spec:
         useDefaultCredentialsProvider: "{{useDefaultCredentialsProvider}}"
         uriEndpointOverride: "{{?uriEndpointOverride}}"
         overrideEndpoint: "{{overrideEndpoint}}"
+        delay: "{{delay}}"
       steps:
       - marshal:
           json:

kamelets/aws-kinesis-source.kamelet.yaml

@@ -84,6 +84,11 @@ spec:
         x-descriptors:
           - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
         default: false
+      delay:
+        title: Delay
+        description: Milliseconds before the next poll of the selected stream
+        type: long
+        default: 500
   types:
     out:
       mediaType: application/octet-stream
@@ -101,5 +106,6 @@ spec:
         useDefaultCredentialsProvider: "{{useDefaultCredentialsProvider}}"
         uriEndpointOverride: "{{?uriEndpointOverride}}"
         overrideEndpoint: "{{overrideEndpoint}}"
+        delay: "{{delay}}"
       steps:
       - to: "kamelet:sink"

kamelets/aws-redshift-source.kamelet.yaml

@@ -77,6 +77,11 @@ spec:
         description: A query to run on a tuple consumed
         type: string
         example: 'DELETE FROM accounts where user_id = :#user_id'
+      delay:
+        title: Delay
+        description: Milliseconds before the next poll from database
+        type: long
+        default: 500
   types:
     out:
       mediaType: application/json
@@ -104,6 +109,7 @@ spec:
       parameters:
         dataSource: "#bean:{{dsBean}}"
         onConsume: "{{?consumedQuery}}"
+        delay: "{{delay}}"
       steps:
       - marshal:
           json: 

kamelets/aws-s3-source.kamelet.yaml

@@ -100,6 +100,11 @@ spec:
         x-descriptors:
           - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
         default: false
+      delay:
+        title: Delay
+        description: Milliseconds before the next poll of the selected bucket
+        type: long
+        default: 500
   dependencies:
     - "camel:aws2-s3"
     - "camel:kamelet"
@@ -118,5 +123,6 @@ spec:
         useDefaultCredentialsProvider: "{{useDefaultCredentialsProvider}}"
         uriEndpointOverride: "{{?uriEndpointOverride}}"
         overrideEndpoint: "{{overrideEndpoint}}"
+        delay: "{{delay}}"
       steps:
       - to: "kamelet:sink"

kamelets/aws-sqs-source.kamelet.yaml

@@ -123,7 +123,12 @@ spec:
         type: boolean
         x-descriptors:
           - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
-        default: false    
+        default: false
+      delay:
+        title: Delay
+        description: Milliseconds before the next poll of the selected stream
+        type: long
+        default: 500
   dependencies:
     - "camel:aws2-sqs"
     - "camel:kamelet"
@@ -140,6 +145,7 @@ spec:
         protocol: "{{?protocol}}"
         useDefaultCredentialsProvider: "{{useDefaultCredentialsProvider}}"
         uriEndpointOverride: "{{?uriEndpointOverride}}"
-        overrideEndpoint: "{{overrideEndpoint}}"  
+        overrideEndpoint: "{{overrideEndpoint}}"
+        delay: "{{delay}}"  
       steps:
       - to: "kamelet:sink"

library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java

@@ -54,7 +54,7 @@ void testGetKamelets() throws Exception {
     @Test
     void testGetKameletsDefinition() throws Exception {
         JSONSchemaProps props = catalog.getKameletDefinition("aws-sqs-source");
-        assertEquals(12, props.getProperties().keySet().size());
+        assertEquals(13, props.getProperties().keySet().size());
         assertTrue(props.getProperties().keySet().contains("queueNameOrArn"));
     }
 

library/camel-kamelets/src/main/resources/kamelets/aws-ddb-streams-source.kamelet.yaml

@@ -89,6 +89,11 @@ spec:
         x-descriptors:
           - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
         default: false
+      delay:
+        title: Delay
+        description: Milliseconds before the next poll from database
+        type: long
+        default: 500
   types:
     out:
       mediaType: application/json
@@ -107,6 +112,7 @@ spec:
         useDefaultCredentialsProvider: "{{useDefaultCredentialsProvider}}"
         uriEndpointOverride: "{{?uriEndpointOverride}}"
         overrideEndpoint: "{{overrideEndpoint}}"
+        delay: "{{delay}}"
       steps:
       - marshal:
           json:

library/camel-kamelets/src/main/resources/kamelets/aws-kinesis-source.kamelet.yaml

@@ -84,6 +84,11 @@ spec:
         x-descriptors:
           - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
         default: false
+      delay:
+        title: Delay
+        description: Milliseconds before the next poll of the selected stream
+        type: long
+        default: 500
   types:
     out:
       mediaType: application/octet-stream
@@ -101,5 +106,6 @@ spec:
         useDefaultCredentialsProvider: "{{useDefaultCredentialsProvider}}"
         uriEndpointOverride: "{{?uriEndpointOverride}}"
         overrideEndpoint: "{{overrideEndpoint}}"
+        delay: "{{delay}}"
       steps:
       - to: "kamelet:sink"

library/camel-kamelets/src/main/resources/kamelets/aws-redshift-source.kamelet.yaml

@@ -77,6 +77,11 @@ spec:
         description: A query to run on a tuple consumed
         type: string
         example: 'DELETE FROM accounts where user_id = :#user_id'
+      delay:
+        title: Delay
+        description: Milliseconds before the next poll from database
+        type: long
+        default: 500
   types:
     out:
       mediaType: application/json
@@ -104,6 +109,7 @@ spec:
       parameters:
         dataSource: "#bean:{{dsBean}}"
         onConsume: "{{?consumedQuery}}"
+        delay: "{{delay}}"
       steps:
       - marshal:
           json: 

library/camel-kamelets/src/main/resources/kamelets/aws-s3-source.kamelet.yaml

@@ -100,6 +100,11 @@ spec:
         x-descriptors:
           - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
         default: false
+      delay:
+        title: Delay
+        description: Milliseconds before the next poll of the selected bucket
+        type: long
+        default: 500
   dependencies:
     - "camel:aws2-s3"
     - "camel:kamelet"
@@ -118,5 +123,6 @@ spec:
         useDefaultCredentialsProvider: "{{useDefaultCredentialsProvider}}"
         uriEndpointOverride: "{{?uriEndpointOverride}}"
         overrideEndpoint: "{{overrideEndpoint}}"
+        delay: "{{delay}}"
       steps:
       - to: "kamelet:sink"

library/camel-kamelets/src/main/resources/kamelets/aws-sqs-source.kamelet.yaml

@@ -123,7 +123,12 @@ spec:
         type: boolean
         x-descriptors:
           - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
-        default: false    
+        default: false
+      delay:
+        title: Delay
+        description: Milliseconds before the next poll of the selected stream
+        type: long
+        default: 500
   dependencies:
     - "camel:aws2-sqs"
     - "camel:kamelet"
@@ -140,6 +145,7 @@ spec:
         protocol: "{{?protocol}}"
         useDefaultCredentialsProvider: "{{useDefaultCredentialsProvider}}"
         uriEndpointOverride: "{{?uriEndpointOverride}}"
-        overrideEndpoint: "{{overrideEndpoint}}"  
+        overrideEndpoint: "{{overrideEndpoint}}"
+        delay: "{{delay}}"  
       steps:
       - to: "kamelet:sink"