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:10 UTC
[camel-kamelets] branch deleteAfterRead-0.9.x created (now 7f0b479b)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch deleteAfterRead-0.9.x
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
at 7f0b479b Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
This branch includes the following new commits:
new c62a8ed3 Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
new f482ea9d Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
new fb89b8ff Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
new 7f0b479b 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.
[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 deleteAfterRead-0.9.x
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit c62a8ed3431e559b5ed42b2f6008fca9fd1a4572
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] 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 deleteAfterRead-0.9.x
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit fb89b8ff4f7a8d8eeee05d0cfb4d1b090215e5a4
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
}
[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 deleteAfterRead-0.9.x
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 7f0b479b992ea23d45a4475d5060ccdf92363dc2
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] 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 deleteAfterRead-0.9.x
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit f482ea9d0f5dbaa01b9ca2c6c5ec5d0b8b4ba54e
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}}"