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)
-}