From 24c4ba91e4f8e8f6bfb8fb44a87d9f7a6a8d4396 Mon Sep 17 00:00:00 2001 From: Keran Yang Date: Fri, 8 Nov 2024 17:43:43 -0500 Subject: [PATCH] chore: update go mod for examples (#170) Signed-off-by: Keran Yang --- pkg/batchmapper/examples/batchmap_flatmap/go.mod | 2 +- pkg/mapper/examples/even_odd/go.mod | 2 +- pkg/mapper/examples/flatmap/go.mod | 2 +- pkg/mapper/examples/forward_message/go.mod | 2 +- pkg/mapper/examples/retry/go.mod | 2 +- pkg/mapper/examples/tickgen/go.mod | 2 +- pkg/mapstreamer/examples/flatmap_stream/go.mod | 2 +- pkg/reducer/examples/counter/go.mod | 2 +- pkg/reducer/examples/sum/go.mod | 2 +- pkg/reducestreamer/examples/counter/go.mod | 2 +- pkg/reducestreamer/examples/sum/go.mod | 2 +- pkg/sessionreducer/examples/counter/go.mod | 2 +- pkg/sessionreducer/examples/sum/go.mod | 2 +- pkg/sideinput/examples/map_sideinput/go.mod | 2 +- pkg/sideinput/examples/map_sideinput/udf/go.mod | 2 +- pkg/sideinput/examples/reduce_sideinput/go.mod | 2 +- pkg/sideinput/examples/reduce_sideinput/udf/go.mod | 2 +- pkg/sideinput/examples/sideinput_function/go.mod | 2 +- pkg/sideinput/examples/simple_sideinput/go.mod | 2 +- pkg/sideinput/examples/simple_sideinput/udf/go.mod | 2 +- pkg/sideinput/examples/simple_source_with_sideinput/go.mod | 2 +- pkg/sideinput/examples/sink_sideinput/go.mod | 2 +- pkg/sinker/examples/fallback/go.mod | 2 +- pkg/sinker/examples/log/go.mod | 2 +- pkg/sinker/examples/redis_sink/go.mod | 2 +- pkg/sourcer/examples/simple_source/go.mod | 2 +- pkg/sourcetransformer/examples/assign_event_time/go.mod | 2 +- pkg/sourcetransformer/examples/event_time_filter/go.mod | 2 +- 28 files changed, 28 insertions(+), 28 deletions(-) diff --git a/pkg/batchmapper/examples/batchmap_flatmap/go.mod b/pkg/batchmapper/examples/batchmap_flatmap/go.mod index fa00e50d..cd04942a 100644 --- a/pkg/batchmapper/examples/batchmap_flatmap/go.mod +++ b/pkg/batchmapper/examples/batchmap_flatmap/go.mod @@ -4,7 +4,7 @@ go 1.21 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.1 +require github.com/numaproj/numaflow-go v0.9.0 require ( golang.org/x/net v0.29.0 // indirect diff --git a/pkg/mapper/examples/even_odd/go.mod b/pkg/mapper/examples/even_odd/go.mod index 5d4b69a8..85dc57e0 100644 --- a/pkg/mapper/examples/even_odd/go.mod +++ b/pkg/mapper/examples/even_odd/go.mod @@ -4,7 +4,7 @@ go 1.21 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.1 +require github.com/numaproj/numaflow-go v0.9.0 require ( golang.org/x/net v0.29.0 // indirect diff --git a/pkg/mapper/examples/flatmap/go.mod b/pkg/mapper/examples/flatmap/go.mod index e4cdd7b8..c8d1fdfa 100644 --- a/pkg/mapper/examples/flatmap/go.mod +++ b/pkg/mapper/examples/flatmap/go.mod @@ -4,7 +4,7 @@ go 1.21 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.1 +require github.com/numaproj/numaflow-go v0.9.0 require ( golang.org/x/net v0.29.0 // indirect diff --git a/pkg/mapper/examples/forward_message/go.mod b/pkg/mapper/examples/forward_message/go.mod index c1dc3be7..89864ff3 100644 --- a/pkg/mapper/examples/forward_message/go.mod +++ b/pkg/mapper/examples/forward_message/go.mod @@ -4,7 +4,7 @@ go 1.21 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.1 +require github.com/numaproj/numaflow-go v0.9.0 require ( golang.org/x/net v0.29.0 // indirect diff --git a/pkg/mapper/examples/retry/go.mod b/pkg/mapper/examples/retry/go.mod index 41a9d813..4231789d 100644 --- a/pkg/mapper/examples/retry/go.mod +++ b/pkg/mapper/examples/retry/go.mod @@ -4,7 +4,7 @@ go 1.21 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.1 +require github.com/numaproj/numaflow-go v0.9.0 require ( golang.org/x/net v0.29.0 // indirect diff --git a/pkg/mapper/examples/tickgen/go.mod b/pkg/mapper/examples/tickgen/go.mod index 988c6b88..320a014d 100644 --- a/pkg/mapper/examples/tickgen/go.mod +++ b/pkg/mapper/examples/tickgen/go.mod @@ -4,7 +4,7 @@ go 1.21 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.1 +require github.com/numaproj/numaflow-go v0.9.0 require ( golang.org/x/net v0.29.0 // indirect diff --git a/pkg/mapstreamer/examples/flatmap_stream/go.mod b/pkg/mapstreamer/examples/flatmap_stream/go.mod index 1b14a67a..1b070f10 100644 --- a/pkg/mapstreamer/examples/flatmap_stream/go.mod +++ b/pkg/mapstreamer/examples/flatmap_stream/go.mod @@ -4,7 +4,7 @@ go 1.21 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.1 +require github.com/numaproj/numaflow-go v0.9.0 require ( golang.org/x/net v0.29.0 // indirect diff --git a/pkg/reducer/examples/counter/go.mod b/pkg/reducer/examples/counter/go.mod index 6cbde198..fbe62e08 100644 --- a/pkg/reducer/examples/counter/go.mod +++ b/pkg/reducer/examples/counter/go.mod @@ -4,7 +4,7 @@ go 1.21 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.1 +require github.com/numaproj/numaflow-go v0.9.0 require ( golang.org/x/net v0.29.0 // indirect diff --git a/pkg/reducer/examples/sum/go.mod b/pkg/reducer/examples/sum/go.mod index 6eb20efb..71ade673 100644 --- a/pkg/reducer/examples/sum/go.mod +++ b/pkg/reducer/examples/sum/go.mod @@ -4,7 +4,7 @@ go 1.21 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.1 +require github.com/numaproj/numaflow-go v0.9.0 require ( golang.org/x/net v0.29.0 // indirect diff --git a/pkg/reducestreamer/examples/counter/go.mod b/pkg/reducestreamer/examples/counter/go.mod index 6cbde198..fbe62e08 100644 --- a/pkg/reducestreamer/examples/counter/go.mod +++ b/pkg/reducestreamer/examples/counter/go.mod @@ -4,7 +4,7 @@ go 1.21 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.1 +require github.com/numaproj/numaflow-go v0.9.0 require ( golang.org/x/net v0.29.0 // indirect diff --git a/pkg/reducestreamer/examples/sum/go.mod b/pkg/reducestreamer/examples/sum/go.mod index 6eb20efb..71ade673 100644 --- a/pkg/reducestreamer/examples/sum/go.mod +++ b/pkg/reducestreamer/examples/sum/go.mod @@ -4,7 +4,7 @@ go 1.21 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.1 +require github.com/numaproj/numaflow-go v0.9.0 require ( golang.org/x/net v0.29.0 // indirect diff --git a/pkg/sessionreducer/examples/counter/go.mod b/pkg/sessionreducer/examples/counter/go.mod index c291ea94..29556dfe 100644 --- a/pkg/sessionreducer/examples/counter/go.mod +++ b/pkg/sessionreducer/examples/counter/go.mod @@ -5,7 +5,7 @@ go 1.21 replace github.com/numaproj/numaflow-go => ../../../.. require ( - github.com/numaproj/numaflow-go v0.8.1 + github.com/numaproj/numaflow-go v0.9.1 go.uber.org/atomic v1.11.0 ) diff --git a/pkg/sessionreducer/examples/sum/go.mod b/pkg/sessionreducer/examples/sum/go.mod index ca46a775..f57b6f8c 100644 --- a/pkg/sessionreducer/examples/sum/go.mod +++ b/pkg/sessionreducer/examples/sum/go.mod @@ -5,7 +5,7 @@ go 1.21 replace github.com/numaproj/numaflow-go => ../../../.. require ( - github.com/numaproj/numaflow-go v0.8.1 + github.com/numaproj/numaflow-go v0.9.0 go.uber.org/atomic v1.11.0 ) diff --git a/pkg/sideinput/examples/map_sideinput/go.mod b/pkg/sideinput/examples/map_sideinput/go.mod index da293eb8..7a8f5b92 100644 --- a/pkg/sideinput/examples/map_sideinput/go.mod +++ b/pkg/sideinput/examples/map_sideinput/go.mod @@ -4,7 +4,7 @@ go 1.21.2 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.1 +require github.com/numaproj/numaflow-go v0.9.0 require ( golang.org/x/net v0.29.0 // indirect diff --git a/pkg/sideinput/examples/map_sideinput/udf/go.mod b/pkg/sideinput/examples/map_sideinput/udf/go.mod index 78ff598e..f19c7c5d 100644 --- a/pkg/sideinput/examples/map_sideinput/udf/go.mod +++ b/pkg/sideinput/examples/map_sideinput/udf/go.mod @@ -6,7 +6,7 @@ replace github.com/numaproj/numaflow-go => ../../../../.. require ( github.com/fsnotify/fsnotify v1.6.0 - github.com/numaproj/numaflow-go v0.8.1 + github.com/numaproj/numaflow-go v0.9.0 ) require ( diff --git a/pkg/sideinput/examples/reduce_sideinput/go.mod b/pkg/sideinput/examples/reduce_sideinput/go.mod index cba75f41..f45d0e0f 100644 --- a/pkg/sideinput/examples/reduce_sideinput/go.mod +++ b/pkg/sideinput/examples/reduce_sideinput/go.mod @@ -4,7 +4,7 @@ go 1.21 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.1 +require github.com/numaproj/numaflow-go v0.9.0 require ( golang.org/x/net v0.29.0 // indirect diff --git a/pkg/sideinput/examples/reduce_sideinput/udf/go.mod b/pkg/sideinput/examples/reduce_sideinput/udf/go.mod index 49c255d7..507b2beb 100644 --- a/pkg/sideinput/examples/reduce_sideinput/udf/go.mod +++ b/pkg/sideinput/examples/reduce_sideinput/udf/go.mod @@ -6,7 +6,7 @@ replace github.com/numaproj/numaflow-go => ../../../../.. require ( github.com/fsnotify/fsnotify v1.7.0 - github.com/numaproj/numaflow-go v0.8.1 + github.com/numaproj/numaflow-go v0.9.0 ) require ( diff --git a/pkg/sideinput/examples/sideinput_function/go.mod b/pkg/sideinput/examples/sideinput_function/go.mod index ed10844d..d5d4c8cd 100644 --- a/pkg/sideinput/examples/sideinput_function/go.mod +++ b/pkg/sideinput/examples/sideinput_function/go.mod @@ -4,7 +4,7 @@ go 1.21 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.1 +require github.com/numaproj/numaflow-go v0.9.0 require ( golang.org/x/net v0.29.0 // indirect diff --git a/pkg/sideinput/examples/simple_sideinput/go.mod b/pkg/sideinput/examples/simple_sideinput/go.mod index 00636a3c..9b330d6b 100644 --- a/pkg/sideinput/examples/simple_sideinput/go.mod +++ b/pkg/sideinput/examples/simple_sideinput/go.mod @@ -4,7 +4,7 @@ go 1.21 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.1 +require github.com/numaproj/numaflow-go v0.9.0 require ( golang.org/x/net v0.29.0 // indirect diff --git a/pkg/sideinput/examples/simple_sideinput/udf/go.mod b/pkg/sideinput/examples/simple_sideinput/udf/go.mod index 8eef3bde..18725d1c 100644 --- a/pkg/sideinput/examples/simple_sideinput/udf/go.mod +++ b/pkg/sideinput/examples/simple_sideinput/udf/go.mod @@ -6,7 +6,7 @@ replace github.com/numaproj/numaflow-go => ../../../../.. require ( github.com/fsnotify/fsnotify v1.6.0 - github.com/numaproj/numaflow-go v0.8.1 + github.com/numaproj/numaflow-go v0.9.0 ) require ( diff --git a/pkg/sideinput/examples/simple_source_with_sideinput/go.mod b/pkg/sideinput/examples/simple_source_with_sideinput/go.mod index 4fca1c04..da5107e8 100644 --- a/pkg/sideinput/examples/simple_source_with_sideinput/go.mod +++ b/pkg/sideinput/examples/simple_source_with_sideinput/go.mod @@ -6,7 +6,7 @@ replace github.com/numaproj/numaflow-go => ../../../.. require ( github.com/fsnotify/fsnotify v1.6.0 - github.com/numaproj/numaflow-go v0.8.1 + github.com/numaproj/numaflow-go v0.9.0 github.com/stretchr/testify v1.9.0 ) diff --git a/pkg/sideinput/examples/sink_sideinput/go.mod b/pkg/sideinput/examples/sink_sideinput/go.mod index ace4831e..735a05a6 100644 --- a/pkg/sideinput/examples/sink_sideinput/go.mod +++ b/pkg/sideinput/examples/sink_sideinput/go.mod @@ -7,7 +7,7 @@ replace github.com/numaproj/numaflow-go => ../../../.. require ( github.com/fsnotify/fsnotify v1.5.1 github.com/go-redis/redis/v8 v8.11.5 - github.com/numaproj/numaflow-go v0.8.1 + github.com/numaproj/numaflow-go v0.9.0 ) require ( diff --git a/pkg/sinker/examples/fallback/go.mod b/pkg/sinker/examples/fallback/go.mod index 820888b4..1cd7e07b 100644 --- a/pkg/sinker/examples/fallback/go.mod +++ b/pkg/sinker/examples/fallback/go.mod @@ -4,7 +4,7 @@ go 1.21 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.1 +require github.com/numaproj/numaflow-go v0.9.0 require ( golang.org/x/net v0.29.0 // indirect diff --git a/pkg/sinker/examples/log/go.mod b/pkg/sinker/examples/log/go.mod index de58ebbb..ac86c784 100644 --- a/pkg/sinker/examples/log/go.mod +++ b/pkg/sinker/examples/log/go.mod @@ -4,7 +4,7 @@ go 1.21 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.1 +require github.com/numaproj/numaflow-go v0.9.0 require ( golang.org/x/net v0.29.0 // indirect diff --git a/pkg/sinker/examples/redis_sink/go.mod b/pkg/sinker/examples/redis_sink/go.mod index 51e19951..98192b69 100644 --- a/pkg/sinker/examples/redis_sink/go.mod +++ b/pkg/sinker/examples/redis_sink/go.mod @@ -6,7 +6,7 @@ replace github.com/numaproj/numaflow-go => ../../../.. require ( github.com/go-redis/redis/v8 v8.11.5 - github.com/numaproj/numaflow-go v0.8.1 + github.com/numaproj/numaflow-go v0.9.0 ) require ( diff --git a/pkg/sourcer/examples/simple_source/go.mod b/pkg/sourcer/examples/simple_source/go.mod index d095c3cf..2a8b4f7f 100644 --- a/pkg/sourcer/examples/simple_source/go.mod +++ b/pkg/sourcer/examples/simple_source/go.mod @@ -6,7 +6,7 @@ replace github.com/numaproj/numaflow-go => ../../../.. require ( github.com/google/uuid v1.6.0 - github.com/numaproj/numaflow-go v0.8.1 + github.com/numaproj/numaflow-go v0.9.0 github.com/stretchr/testify v1.9.0 ) diff --git a/pkg/sourcetransformer/examples/assign_event_time/go.mod b/pkg/sourcetransformer/examples/assign_event_time/go.mod index 6e7e70c9..54232c8a 100644 --- a/pkg/sourcetransformer/examples/assign_event_time/go.mod +++ b/pkg/sourcetransformer/examples/assign_event_time/go.mod @@ -4,7 +4,7 @@ go 1.21 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.1 +require github.com/numaproj/numaflow-go v0.9.0 require ( golang.org/x/net v0.29.0 // indirect diff --git a/pkg/sourcetransformer/examples/event_time_filter/go.mod b/pkg/sourcetransformer/examples/event_time_filter/go.mod index c91400a8..b7ca4732 100644 --- a/pkg/sourcetransformer/examples/event_time_filter/go.mod +++ b/pkg/sourcetransformer/examples/event_time_filter/go.mod @@ -5,7 +5,7 @@ go 1.21 replace github.com/numaproj/numaflow-go => ../../../.. require ( - github.com/numaproj/numaflow-go v0.8.1 + github.com/numaproj/numaflow-go v0.9.0 github.com/stretchr/testify v1.9.0 )