Skip to content

Commit

Permalink
Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
Browse files Browse the repository at this point in the history
Signed-off-by: Andrea Cosentino <ancosen@gmail.com>
  • Loading branch information
oscerd committed Oct 28, 2022
1 parent 528ff08 commit e8106f5
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 0 deletions.
2 changes: 2 additions & 0 deletions kamelets/azure-storage-blob-source.kamelet.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand Down
2 changes: 2 additions & 0 deletions script/validator/validator.go
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand All @@ -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
}
Expand Down

0 comments on commit e8106f5

Please sign in to comment.