Skip to content

Commit

Permalink
chore: fix go.mod
Browse files Browse the repository at this point in the history 
Signed-off-by: Vigith Maurice <[email protected]>
  • Loading branch information
@vigith
vigith committed Feb 22, 2025
1 parent 0bf0936 commit feae677
Show file tree
Hide file tree
Showing 29 changed files with 87 additions and 29 deletions.
4 changes: 3 additions & 1 deletion pkg/batchmapper/examples/batchmap_flatmap/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module batchmap-flatmap

go 1.21
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/mapper/examples/even_odd/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module even_odd

go 1.21
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/mapper/examples/flatmap/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module flatmap

go 1.21
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/mapper/examples/forward_message/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module forward_message

go 1.21
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/mapper/examples/retry/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module retry

go 1.21
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/mapper/examples/slow_cat/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module even_odd

go 1.21
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/mapper/examples/tickgen/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module tickgen

go 1.21
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/mapstreamer/examples/flatmap_stream/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module flatmap_stream

go 1.21
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/reducer/examples/counter/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module counter

go 1.21
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/reducer/examples/sum/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module sum

go 1.21
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/reducestreamer/examples/counter/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module counter

go 1.21
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/reducestreamer/examples/sum/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module sum

go 1.21
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/sessionreducer/examples/counter/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module counter

go 1.21
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/sessionreducer/examples/sum/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module sum

go 1.21
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/sideinput/examples/map_sideinput/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module map_sideinput

go 1.21.2
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/sideinput/examples/map_sideinput/udf/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module udf

go 1.21.2
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/sideinput/examples/reduce_sideinput/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module reduce_sideinput

go 1.21
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/sideinput/examples/reduce_sideinput/udf/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module udf

go 1.21.2
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/sideinput/examples/sideinput_function/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module even_odd_sideinput

go 1.21
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/sideinput/examples/simple_sideinput/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module simple_sideinput

go 1.21
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/sideinput/examples/simple_sideinput/udf/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module udf

go 1.21
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/sideinput/examples/simple_source_with_sideinput/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module simple_source_with_sideinput

go 1.21
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/sideinput/examples/sink_sideinput/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module sink_sideinput

go 1.21
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/sinker/examples/fallback/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module fallback

go 1.21
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/sinker/examples/log/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module log_sink

go 1.21
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/sinker/examples/redis_sink/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module redis-e2e-test-sink

go 1.21
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/sourcer/examples/simple_source/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module simple_source

go 1.21
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/sourcetransformer/examples/assign_event_time/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module assign_event_time

go 1.21
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../..

Expand Down
4 changes: 3 additions & 1 deletion pkg/sourcetransformer/examples/event_time_filter/go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
module event_time_filter

go 1.21
go 1.22

toolchain go1.23.1

replace github.com/numaproj/numaflow-go => ../../../..

Expand Down

0 comments on commit feae677

Please sign in to comment.