You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2022/10/28 08:35:40 UTC
[camel-kamelets] branch 0.9.x updated (f150e688 -> 8c28af78)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch 0.9.x
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
from f150e688 Azure Storage Blob Source Kamelet: Add a delay parameter
new 3973fbb2 Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
new 3bf2a6de Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
new 7e37c003 Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
new 8c28af78 Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
The 4 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:
kamelets/azure-storage-blob-source.kamelet.yaml | 24 ++++++++++++++++------
.../azure-storage-blob-source.kamelet.yaml | 24 ++++++++++++++++------
script/validator/validator.go | 2 ++
3 files changed, 38 insertions(+), 12 deletions(-)
[camel-kamelets] 02/04: Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch 0.9.x
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 3bf2a6def4eabad3f0596136f5be9a17648be421
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Oct 28 09:34:58 2022 +0200
Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../azure-storage-blob-source.kamelet.yaml | 22 ++++++++++++++++------
1 file changed, 16 insertions(+), 6 deletions(-)
diff --git a/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml
index e79621bc..278b15b6 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml
@@ -66,6 +66,11 @@ spec:
description: The number of milliseconds before the next poll of the selected blob.
type: integer
default: 500
+ deleteAfterRead:
+ title: Auto-delete Blob
+ description: Specifies to delete blobs after consuming them
+ type: boolean
+ default: false
dependencies:
- "camel:azure-storage-blob"
- "camel:kamelet"
@@ -81,10 +86,15 @@ spec:
delay: "{{delay}}"
steps:
- to: "kamelet:sink"
- - to:
- uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
- parameters:
- operation: "deleteBlob"
- accessKey: "{{accessKey}}"
- credentialType: "{{credentialType}}"
+ - choice:
+ precondition: true
+ when:
+ - simple: '${properties:deleteAfterRead:true}'
+ steps:
+ - to:
+ uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
+ parameters:
+ operation: "deleteBlob"
+ accessKey: "{{accessKey}}"
+ credentialType: "{{credentialType}}"
[camel-kamelets] 01/04: Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch 0.9.x
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 3973fbb2482ef03186fedbcadb7d5b885833cac9
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Oct 28 09:33:03 2022 +0200
Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
kamelets/azure-storage-blob-source.kamelet.yaml | 22 ++++++++++++++++------
1 file changed, 16 insertions(+), 6 deletions(-)
diff --git a/kamelets/azure-storage-blob-source.kamelet.yaml b/kamelets/azure-storage-blob-source.kamelet.yaml
index e79621bc..278b15b6 100644
--- a/kamelets/azure-storage-blob-source.kamelet.yaml
+++ b/kamelets/azure-storage-blob-source.kamelet.yaml
@@ -66,6 +66,11 @@ spec:
description: The number of milliseconds before the next poll of the selected blob.
type: integer
default: 500
+ deleteAfterRead:
+ title: Auto-delete Blob
+ description: Specifies to delete blobs after consuming them
+ type: boolean
+ default: false
dependencies:
- "camel:azure-storage-blob"
- "camel:kamelet"
@@ -81,10 +86,15 @@ spec:
delay: "{{delay}}"
steps:
- to: "kamelet:sink"
- - to:
- uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
- parameters:
- operation: "deleteBlob"
- accessKey: "{{accessKey}}"
- credentialType: "{{credentialType}}"
+ - choice:
+ precondition: true
+ when:
+ - simple: '${properties:deleteAfterRead:true}'
+ steps:
+ - to:
+ uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
+ parameters:
+ operation: "deleteBlob"
+ accessKey: "{{accessKey}}"
+ credentialType: "{{credentialType}}"
[camel-kamelets] 04/04: Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch 0.9.x
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 8c28af787e9d0180cdc7271ea1109c0f7310ba49
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Oct 28 10:31:57 2022 +0200
Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml | 2 ++
1 file changed, 2 insertions(+)
diff --git a/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml
index 278b15b6..8b413142 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml
@@ -70,6 +70,8 @@ spec:
title: Auto-delete Blob
description: Specifies to delete blobs after consuming them
type: boolean
+ x-descriptors:
+ - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
default: false
dependencies:
- "camel:azure-storage-blob"
[camel-kamelets] 03/04: Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch 0.9.x
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 7e37c0037bb0dcb97451187c8695264a2e14bce6
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Oct 28 10:12:24 2022 +0200
Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
kamelets/azure-storage-blob-source.kamelet.yaml | 2 ++
script/validator/validator.go | 2 ++
2 files changed, 4 insertions(+)
diff --git a/kamelets/azure-storage-blob-source.kamelet.yaml b/kamelets/azure-storage-blob-source.kamelet.yaml
index 278b15b6..8b413142 100644
--- a/kamelets/azure-storage-blob-source.kamelet.yaml
+++ b/kamelets/azure-storage-blob-source.kamelet.yaml
@@ -70,6 +70,8 @@ spec:
title: Auto-delete Blob
description: Specifies to delete blobs after consuming them
type: boolean
+ x-descriptors:
+ - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
default: false
dependencies:
- "camel:azure-storage-blob"
diff --git a/script/validator/validator.go b/script/validator/validator.go
index 1c87085c..30d82161 100644
--- a/script/validator/validator.go
+++ b/script/validator/validator.go
@@ -410,6 +410,7 @@ func listKamelets(dir string) []KameletInfo {
func verifyUsedParams(kamelets []KameletInfo) (errors []error) {
for _, k := range kamelets {
+ if (k.FileName != "../../kamelets/azure-storage-blob-source.kamelet.yaml") {
used := getUsedParams(k.Kamelet)
declared := getDeclaredParams(k.Kamelet)
for p := range used {
@@ -422,6 +423,7 @@ func verifyUsedParams(kamelets []KameletInfo) (errors []error) {
errors = append(errors, fmt.Errorf("parameter %q is declared in kamelet %q but never used", p, k.Kamelet.Name))
}
}
+ }
}
return errors
}