From 9c71cc41db5082455a2546139d145917ccdc65ce Mon Sep 17 00:00:00 2001 From: Sreekanth Date: Mon, 23 Sep 2024 15:12:22 +0530 Subject: [PATCH] Fix sourcetransformer example (event-time-filter) Signed-off-by: Sreekanth --- .../examples/event_time_filter/go.mod | 1 + .../examples/event_time_filter/go.sum | 2 ++ .../examples/event_time_filter/impl/filter_test.go | 10 ++++++++++ 3 files changed, 13 insertions(+) diff --git a/pkg/sourcetransformer/examples/event_time_filter/go.mod b/pkg/sourcetransformer/examples/event_time_filter/go.mod index d8c44a3a..c91400a8 100644 --- 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 index 47607cf0..15b67493 100644 --- 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 index fb8b5b06..2ddd5cd7 100644 --- 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"}