From e14d1a2276328bc1d502786683b76d454d4986e7 Mon Sep 17 00:00:00 2001 From: Yashash H L Date: Sun, 15 Sep 2024 03:01:41 +0530 Subject: [PATCH] chore: update examples to latest sdk version (#148) Signed-off-by: Yashash H L --- pkg/batchmapper/examples/batchmap_flatmap/go.mod | 2 +- pkg/batchmapper/examples/batchmap_flatmap/go.sum | 5 ----- 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 +- 29 files changed, 28 insertions(+), 33 deletions(-) diff --git a/pkg/batchmapper/examples/batchmap_flatmap/go.mod b/pkg/batchmapper/examples/batchmap_flatmap/go.mod index 99f7873e..c02180a2 100644 --- a/pkg/batchmapper/examples/batchmap_flatmap/go.mod +++ b/pkg/batchmapper/examples/batchmap_flatmap/go.mod @@ -4,7 +4,7 @@ go 1.20 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.0 +require github.com/numaproj/numaflow-go v0.8.1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/batchmapper/examples/batchmap_flatmap/go.sum b/pkg/batchmapper/examples/batchmap_flatmap/go.sum index e884f1a5..e5697aab 100644 --- a/pkg/batchmapper/examples/batchmap_flatmap/go.sum +++ b/pkg/batchmapper/examples/batchmap_flatmap/go.sum @@ -1,15 +1,11 @@ github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= -github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk= github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg= github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= -github.com/google/go-cmp v0.5.9/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= -github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= -github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4= go.uber.org/atomic v1.11.0 h1:ZvwS0R+56ePWxUNi+Atn9dWONBPp/AUETXlHW0DxSjE= go.uber.org/atomic v1.11.0/go.mod h1:LUxbIzbOniOlMKjJjyPfpl4v+PKK2cNJn91OQbhoJI0= golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= @@ -30,4 +26,3 @@ google.golang.org/protobuf v1.26.0/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQ google.golang.org/protobuf v1.31.0 h1:g0LDEJHgrBl9N9r17Ru3sqWhkIx2NB67okBHPwC7hs8= google.golang.org/protobuf v1.31.0/go.mod h1:HV8QOd/L58Z+nl8r43ehVNZIU/HEI6OcFqwMG9pJV4I= gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= -gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= diff --git a/pkg/mapper/examples/even_odd/go.mod b/pkg/mapper/examples/even_odd/go.mod index dcde2eb1..cdc7a700 100644 --- a/pkg/mapper/examples/even_odd/go.mod +++ b/pkg/mapper/examples/even_odd/go.mod @@ -4,7 +4,7 @@ go 1.20 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.0 +require github.com/numaproj/numaflow-go v0.8.1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/mapper/examples/flatmap/go.mod b/pkg/mapper/examples/flatmap/go.mod index ffccc83a..b66b5233 100644 --- a/pkg/mapper/examples/flatmap/go.mod +++ b/pkg/mapper/examples/flatmap/go.mod @@ -4,7 +4,7 @@ go 1.20 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.0 +require github.com/numaproj/numaflow-go v0.8.1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/mapper/examples/forward_message/go.mod b/pkg/mapper/examples/forward_message/go.mod index 641a20c5..31ec1bd5 100644 --- a/pkg/mapper/examples/forward_message/go.mod +++ b/pkg/mapper/examples/forward_message/go.mod @@ -4,7 +4,7 @@ go 1.20 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.0 +require github.com/numaproj/numaflow-go v0.8.1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/mapper/examples/retry/go.mod b/pkg/mapper/examples/retry/go.mod index fefcac61..1c19ae6c 100644 --- a/pkg/mapper/examples/retry/go.mod +++ b/pkg/mapper/examples/retry/go.mod @@ -4,7 +4,7 @@ go 1.20 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.0 +require github.com/numaproj/numaflow-go v0.8.1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/mapper/examples/tickgen/go.mod b/pkg/mapper/examples/tickgen/go.mod index 6936777e..01e3ccc8 100644 --- a/pkg/mapper/examples/tickgen/go.mod +++ b/pkg/mapper/examples/tickgen/go.mod @@ -4,7 +4,7 @@ go 1.20 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.0 +require github.com/numaproj/numaflow-go v0.8.1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/mapstreamer/examples/flatmap_stream/go.mod b/pkg/mapstreamer/examples/flatmap_stream/go.mod index 946573ed..9c9dc6f7 100644 --- a/pkg/mapstreamer/examples/flatmap_stream/go.mod +++ b/pkg/mapstreamer/examples/flatmap_stream/go.mod @@ -4,7 +4,7 @@ go 1.20 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.0 +require github.com/numaproj/numaflow-go v0.8.1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/reducer/examples/counter/go.mod b/pkg/reducer/examples/counter/go.mod index 2d704cc9..569851fa 100644 --- a/pkg/reducer/examples/counter/go.mod +++ b/pkg/reducer/examples/counter/go.mod @@ -4,7 +4,7 @@ go 1.20 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.0 +require github.com/numaproj/numaflow-go v0.8.1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/reducer/examples/sum/go.mod b/pkg/reducer/examples/sum/go.mod index f2499195..80928b6b 100644 --- a/pkg/reducer/examples/sum/go.mod +++ b/pkg/reducer/examples/sum/go.mod @@ -4,7 +4,7 @@ go 1.20 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.0 +require github.com/numaproj/numaflow-go v0.8.1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/reducestreamer/examples/counter/go.mod b/pkg/reducestreamer/examples/counter/go.mod index 2d704cc9..569851fa 100644 --- a/pkg/reducestreamer/examples/counter/go.mod +++ b/pkg/reducestreamer/examples/counter/go.mod @@ -4,7 +4,7 @@ go 1.20 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.0 +require github.com/numaproj/numaflow-go v0.8.1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/reducestreamer/examples/sum/go.mod b/pkg/reducestreamer/examples/sum/go.mod index f2499195..80928b6b 100644 --- a/pkg/reducestreamer/examples/sum/go.mod +++ b/pkg/reducestreamer/examples/sum/go.mod @@ -4,7 +4,7 @@ go 1.20 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.0 +require github.com/numaproj/numaflow-go v0.8.1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/sessionreducer/examples/counter/go.mod b/pkg/sessionreducer/examples/counter/go.mod index 0d1177e7..46dd0685 100644 --- a/pkg/sessionreducer/examples/counter/go.mod +++ b/pkg/sessionreducer/examples/counter/go.mod @@ -5,7 +5,7 @@ go 1.20 replace github.com/numaproj/numaflow-go => ../../../.. require ( - github.com/numaproj/numaflow-go v0.8.0 + github.com/numaproj/numaflow-go v0.8.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 19fe9d5a..da8981a7 100644 --- a/pkg/sessionreducer/examples/sum/go.mod +++ b/pkg/sessionreducer/examples/sum/go.mod @@ -5,7 +5,7 @@ go 1.20 replace github.com/numaproj/numaflow-go => ../../../.. require ( - github.com/numaproj/numaflow-go v0.8.0 + github.com/numaproj/numaflow-go v0.8.1 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 1e085301..87dbe501 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.0 +require github.com/numaproj/numaflow-go v0.8.1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/sideinput/examples/map_sideinput/udf/go.mod b/pkg/sideinput/examples/map_sideinput/udf/go.mod index 2e07e25b..81192dd7 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.0 + github.com/numaproj/numaflow-go v0.8.1 ) require ( diff --git a/pkg/sideinput/examples/reduce_sideinput/go.mod b/pkg/sideinput/examples/reduce_sideinput/go.mod index bc64ab5f..ba46e4f7 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.0 +require github.com/numaproj/numaflow-go v0.8.1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/sideinput/examples/reduce_sideinput/udf/go.mod b/pkg/sideinput/examples/reduce_sideinput/udf/go.mod index 877b52b8..4601d15c 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.0 + github.com/numaproj/numaflow-go v0.8.1 ) require ( diff --git a/pkg/sideinput/examples/sideinput_function/go.mod b/pkg/sideinput/examples/sideinput_function/go.mod index ef2619b4..f32300fe 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.0 +require github.com/numaproj/numaflow-go v0.8.1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/sideinput/examples/simple_sideinput/go.mod b/pkg/sideinput/examples/simple_sideinput/go.mod index ede6584d..6b4ee185 100644 --- a/pkg/sideinput/examples/simple_sideinput/go.mod +++ b/pkg/sideinput/examples/simple_sideinput/go.mod @@ -4,7 +4,7 @@ go 1.20 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.0 +require github.com/numaproj/numaflow-go v0.8.1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/sideinput/examples/simple_sideinput/udf/go.mod b/pkg/sideinput/examples/simple_sideinput/udf/go.mod index 0c14f6ac..9ab933b5 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.0 + github.com/numaproj/numaflow-go v0.8.1 ) require ( diff --git a/pkg/sideinput/examples/simple_source_with_sideinput/go.mod b/pkg/sideinput/examples/simple_source_with_sideinput/go.mod index 700b59c1..10257414 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.0 + github.com/numaproj/numaflow-go v0.8.1 github.com/stretchr/testify v1.8.1 ) diff --git a/pkg/sideinput/examples/sink_sideinput/go.mod b/pkg/sideinput/examples/sink_sideinput/go.mod index a3b8be8a..ee2edd8d 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.0 + github.com/numaproj/numaflow-go v0.8.1 ) require ( diff --git a/pkg/sinker/examples/fallback/go.mod b/pkg/sinker/examples/fallback/go.mod index 893f1ee3..7de842da 100644 --- a/pkg/sinker/examples/fallback/go.mod +++ b/pkg/sinker/examples/fallback/go.mod @@ -4,7 +4,7 @@ go 1.20 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.0 +require github.com/numaproj/numaflow-go v0.8.1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/sinker/examples/log/go.mod b/pkg/sinker/examples/log/go.mod index b571d4d3..7bc10dfe 100644 --- a/pkg/sinker/examples/log/go.mod +++ b/pkg/sinker/examples/log/go.mod @@ -4,7 +4,7 @@ go 1.20 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.0 +require github.com/numaproj/numaflow-go v0.8.1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/sinker/examples/redis_sink/go.mod b/pkg/sinker/examples/redis_sink/go.mod index 3e62dceb..69174673 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.0 + github.com/numaproj/numaflow-go v0.8.1 ) require ( diff --git a/pkg/sourcer/examples/simple_source/go.mod b/pkg/sourcer/examples/simple_source/go.mod index 56e8dc97..6b5a84a8 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.3.0 - github.com/numaproj/numaflow-go v0.8.0 + github.com/numaproj/numaflow-go v0.8.1 github.com/stretchr/testify v1.8.1 ) diff --git a/pkg/sourcetransformer/examples/assign_event_time/go.mod b/pkg/sourcetransformer/examples/assign_event_time/go.mod index 50a17e14..92693a4c 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.20 replace github.com/numaproj/numaflow-go => ../../../.. -require github.com/numaproj/numaflow-go v0.8.0 +require github.com/numaproj/numaflow-go v0.8.1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/sourcetransformer/examples/event_time_filter/go.mod b/pkg/sourcetransformer/examples/event_time_filter/go.mod index 156b9909..ebff8577 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.20 replace github.com/numaproj/numaflow-go => ../../../.. require ( - github.com/numaproj/numaflow-go v0.8.0 + github.com/numaproj/numaflow-go v0.8.1 github.com/stretchr/testify v1.8.1 )