test: added rust sdk test for source transformer (#1756)

Signed-off-by: shubham <shubhamdixit863@gmail.com>

test/sdks-e2e/sdks_test.go

@@ -141,7 +141,7 @@ func (s *SDKsSuite) TestSourceTransformer() {
 	}
 
 	var wg sync.WaitGroup
-	wg.Add(3)
+	wg.Add(4)
 	go func() {
 		defer wg.Done()
 		s.testSourceTransformer("python")
@@ -154,6 +154,10 @@ func (s *SDKsSuite) TestSourceTransformer() {
 		defer wg.Done()
 		s.testSourceTransformer("go")
 	}()
+	go func() {
+		defer wg.Done()
+		s.testSourceTransformer("rust")
+	}()
 	wg.Wait()
 }
 

test/sdks-e2e/testdata/transformer/event-time-filter-rust.yaml

@@ -0,0 +1,46 @@
+apiVersion: numaflow.numaproj.io/v1alpha1
+kind: Pipeline
+metadata:
+  name: event-time-filter-rust
+spec:
+  vertices:
+    - name: in
+      source:
+        http: {}
+        transformer:
+          container:
+            image: quay.io/numaio/numaflow-rust/mapt-event-time-filter:stable
+            imagePullPolicy: Always
+    - name: sink-within-2022
+      partitions: 2
+      scale:
+        min: 1
+      sink:
+        log: {}
+    - name: sink-after-2022
+      scale:
+        min: 1
+      sink:
+        log: {}
+    - name: sink-all
+      scale:
+        min: 1
+      sink:
+        log: {}
+  edges:
+    - from: in
+      to: sink-within-2022
+      conditions:
+        tags:
+          operator: or
+          values:
+            - within_year_2022
+    - from: in
+      to: sink-after-2022
+      conditions:
+        tags:
+          operator: or
+          values:
+            - after_year_2022
+    - from: in
+      to: sink-all