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:28:53 UTC
[camel-kamelets] branch main updated (373e9739 -> e8106f53)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
from 373e9739 Updated CHANGELOG.md
new c96a4ee5 Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
new 528ff083 Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
new e8106f53 Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
The 3 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 | 22 ++++++++++++++------
script/validator/validator.go | 2 ++
3 files changed, 36 insertions(+), 12 deletions(-)
[camel-kamelets] 01/03: 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 main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit c96a4ee53c9988a8953b653df2b992ecc6693cb1
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 85357e27..c8a51e8f 100644
--- a/kamelets/azure-storage-blob-source.kamelet.yaml
+++ b/kamelets/azure-storage-blob-source.kamelet.yaml
@@ -68,6 +68,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"
@@ -98,10 +103,15 @@ spec:
- process:
ref: "{{duplicateHeaders}}"
- 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] 03/03: 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 main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit e8106f53cef69ed556d7fa1f7e9dfb2f6c0b0b78
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 c8a51e8f..7a73e50c 100644
--- a/kamelets/azure-storage-blob-source.kamelet.yaml
+++ b/kamelets/azure-storage-blob-source.kamelet.yaml
@@ -72,6 +72,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
}
[camel-kamelets] 02/03: 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 main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 528ff08328bbf46ee34b5dd52dd1a0c08426cae4
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 85357e27..c8a51e8f 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
@@ -68,6 +68,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"
@@ -98,10 +103,15 @@ spec:
- process:
ref: "{{duplicateHeaders}}"
- 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}}"