You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by pc...@apache.org on 2022/08/08 09:48:28 UTC
[camel-k] 03/03: chore(e2e): replace createTimerKamelet func
This is an automated email from the ASF dual-hosted git repository.
pcongiusti pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-k.git
commit c66a382e1f4d33107e8ea3647a59ee5627019664
Author: Pasquale Congiusti <pa...@gmail.com>
AuthorDate: Mon Aug 8 09:12:15 2022 +0200
chore(e2e): replace createTimerKamelet func
---
e2e/global/common/kamelet_binding_test.go | 28 +---------------------------
1 file changed, 1 insertion(+), 27 deletions(-)
diff --git a/e2e/global/common/kamelet_binding_test.go b/e2e/global/common/kamelet_binding_test.go
index ab290295b..a98854254 100644
--- a/e2e/global/common/kamelet_binding_test.go
+++ b/e2e/global/common/kamelet_binding_test.go
@@ -97,7 +97,7 @@ func TestKameletBinding(t *testing.T) {
// Kamelet binding with traits testing
t.Run("test kamelet binding with trait", func(t *testing.T) {
RegisterTestingT(t)
- Expect(createTimerKamelet(ns, "my-own-timer-source")()).To(Succeed())
+ Expect(CreateTimerKamelet(ns, "my-own-timer-source")()).To(Succeed())
// Log sink kamelet exists from previous test
from := corev1.ObjectReference{
@@ -172,29 +172,3 @@ func createErrorProducerKamelet(ns string, name string) func() error {
return CreateKamelet(ns, name, flow, props, nil)
}
-
-func createTimerKamelet(ns string, name string) func() error {
- props := map[string]v1alpha1.JSONSchemaProp{
- "message": {
- Type: "string",
- },
- }
-
- flow := map[string]interface{}{
- "from": map[string]interface{}{
- "uri": "timer:tick",
- "steps": []map[string]interface{}{
- {
- "set-body": map[string]interface{}{
- "constant": "{{message}}",
- },
- },
- {
- "to": "kamelet:sink",
- },
- },
- },
- }
-
- return CreateKamelet(ns, name, flow, props, nil)
-}