This is an automated email from the ASF dual-hosted git repository.
tsato pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-k.git
commit 0cd7f11fc3711c100bd2244d9a2c94248f3dd190
Author: Tadayoshi Sato <sato.tadayo...@gmail.com>
AuthorDate: Fri Jul 15 16:55:00 2022 +0900
chore(e2e): refactor e2e/global/common
---
e2e/global/common/kamelet_binding_test.go | 9 +++++----
1 file changed, 5 insertions(+), 4 deletions(-)
diff --git a/e2e/global/common/kamelet_binding_test.go
b/e2e/global/common/kamelet_binding_test.go
index dab663ac1..2c88d4e2c 100644
--- a/e2e/global/common/kamelet_binding_test.go
+++ b/e2e/global/common/kamelet_binding_test.go
@@ -38,8 +38,8 @@ func TestErrorHandler(t *testing.T) {
operatorID := "camel-k-kamelet-errorhandler"
Expect(KamelInstallWithID(operatorID,
ns).Execute()).To(Succeed())
- Expect(CreateErrorProducerKamelet(ns,
"my-own-error-producer-source")()).To(Succeed())
- Expect(CreateLogKamelet(ns, "my-own-log-sink")()).To(Succeed())
+ Expect(createErrorProducerKamelet(ns,
"my-own-error-producer-source")()).To(Succeed())
+ Expect(createLogKamelet(ns, "my-own-log-sink")()).To(Succeed())
from := corev1.ObjectReference{
Kind: "Kamelet",
Name: "my-own-error-producer-source",
@@ -92,7 +92,7 @@ func TestErrorHandler(t *testing.T) {
})
}
-func CreateLogKamelet(ns string, name string) func() error {
+func createLogKamelet(ns string, name string) func() error {
flow := map[string]interface{}{
"from": map[string]interface{}{
"uri": "kamelet:source",
@@ -109,10 +109,11 @@ func CreateLogKamelet(ns string, name string) func()
error {
Type: "string",
},
}
+
return CreateKamelet(ns, name, flow, props, nil)
}
-func CreateErrorProducerKamelet(ns string, name string) func() error {
+func createErrorProducerKamelet(ns string, name string) func() error {
props := map[string]v1alpha1.JSONSchemaProp{
"message": {
Type: "string",
