Fix sourcetransformer example (event-time-filter)

Signed-off-by: Sreekanth <[email protected]>
numaproj · Sep 23, 2024 · 9c71cc4 · 9c71cc4
1 parent 99bdd08
commit 9c71cc4
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 0 deletions.
diff --git a/pkg/sourcetransformer/examples/event_time_filter/go.mod b/pkg/sourcetransformer/examples/event_time_filter/go.mod
@@ -15,6 +15,7 @@ require (
 	github.com/pmezard/go-difflib v1.0.0 // indirect
 	github.com/rogpeppe/go-internal v1.11.0 // indirect
 	golang.org/x/net v0.29.0 // indirect
+	golang.org/x/sync v0.8.0 // indirect
 	golang.org/x/sys v0.25.0 // indirect
 	golang.org/x/text v0.18.0 // indirect
 	google.golang.org/genproto/googleapis/rpc v0.0.0-20240903143218-8af14fe29dc1 // indirect

diff --git a/pkg/sourcetransformer/examples/event_time_filter/go.sum b/pkg/sourcetransformer/examples/event_time_filter/go.sum
@@ -15,6 +15,8 @@ github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsT
 github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
 golang.org/x/net v0.29.0 h1:5ORfpBpCs4HzDYoodCDBbwHzdR5UrLBZ3sOnUJmFoHo=
 golang.org/x/net v0.29.0/go.mod h1:gLkgy8jTGERgjzMic6DS9+SP0ajcu6Xu3Orq/SpETg0=
+golang.org/x/sync v0.8.0 h1:3NFvSEYkUoMifnESzZl15y791HH1qU2xm6eCJU5ZPXQ=
+golang.org/x/sync v0.8.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
 golang.org/x/sys v0.25.0 h1:r+8e+loiHxRqhXVl6ML1nO3l1+oFoWbnlu2Ehimmi34=
 golang.org/x/sys v0.25.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
 golang.org/x/text v0.18.0 h1:XvMDiNzPAl0jr17s6W9lcaIhGUfUORdGCNsuLmPG224=

diff --git a/pkg/sourcetransformer/examples/event_time_filter/impl/filter_test.go b/pkg/sourcetransformer/examples/event_time_filter/impl/filter_test.go
@@ -23,6 +23,10 @@ func (d beforeYear2022Datum) Watermark() time.Time {
 	return time.Now()
 }
 
+func (d beforeYear2022Datum) Headers() map[string]string {
+	return map[string]string{}
+}
+
 type withinYear2022Datum struct{}
 
 func (d withinYear2022Datum) ID() string {
@@ -39,6 +43,9 @@ func (d withinYear2022Datum) EventTime() time.Time {
 func (d withinYear2022Datum) Watermark() time.Time {
 	return time.Now()
 }
+func (d withinYear2022Datum) Headers() map[string]string {
+	return map[string]string{}
+}
 
 type afterYear2022Datum struct{}
 
@@ -52,6 +59,9 @@ func (d afterYear2022Datum) EventTime() time.Time {
 func (d afterYear2022Datum) Watermark() time.Time {
 	return time.Now()
 }
+func (d afterYear2022Datum) Headers() map[string]string {
+	return map[string]string{}
+}
 
 func Test_FilterEventTime(t *testing.T) {
 	testKeys := []string{"test-key"}