diff --git a/pkg/info/server_info_test.go b/pkg/info/server_info_test.go index c30a7b65..c10e66d5 100644 --- a/pkg/info/server_info_test.go +++ b/pkg/info/server_info_test.go @@ -55,10 +55,11 @@ func Test_Read_Write(t *testing.T) { filepath := os.TempDir() + "/server-info" defer os.Remove(filepath) info := &ServerInfo{ - Protocol: TCP, - Language: Java, - Version: "11", - Metadata: map[string]string{"key1": "value1", "key2": "value2"}, + Protocol: TCP, + Language: Java, + MinimumClientVersion: MinimumClientVersion, + Version: "11", + Metadata: map[string]string{"key1": "value1", "key2": "value2"}, } err := Write(info, WithServerInfoFilePath(filepath)) assert.NoError(t, err) diff --git a/pkg/info/types.go b/pkg/info/types.go index 0da0a4ef..fcbd7d1a 100644 --- a/pkg/info/types.go +++ b/pkg/info/types.go @@ -15,10 +15,13 @@ const ( Java Language = "java" ) +const MinimumClientVersion = ">= 1.2.0-0" + // ServerInfo is the information about the server type ServerInfo struct { - Protocol Protocol `json:"protocol"` - Language Language `json:"language"` - Version string `json:"version"` - Metadata map[string]string `json:"metadata"` + Protocol Protocol `json:"protocol"` + Language Language `json:"language"` + MinimumClientVersion string `json:"minimumClientVersion"` + Version string `json:"version"` + Metadata map[string]string `json:"metadata"` } diff --git a/pkg/mapper/examples/even_odd/go.mod b/pkg/mapper/examples/even_odd/go.mod index a90a11ef..741027d5 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.6.0 +require github.com/numaproj/numaflow-go v0.7.0-rc1 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 b92c7843..a27c3293 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.6.0 +require github.com/numaproj/numaflow-go v0.7.0-rc1 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 a90a11ef..741027d5 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.6.0 +require github.com/numaproj/numaflow-go v0.7.0-rc1 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 f23d6bd1..83de3a0c 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.6.0 +require github.com/numaproj/numaflow-go v0.7.0-rc1 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 f5dbf906..441d02f3 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.6.0 +require github.com/numaproj/numaflow-go v0.7.0-rc1 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 ca0e15cf..7814ed6a 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.6.0 +require github.com/numaproj/numaflow-go v0.7.0-rc1 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 a3d73e82..4ad3c231 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.6.0 +require github.com/numaproj/numaflow-go v0.7.0-rc1 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 b6c66010..cc8cbe50 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.6.0 +require github.com/numaproj/numaflow-go v0.7.0-rc1 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 a3d73e82..4ad3c231 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.6.0 +require github.com/numaproj/numaflow-go v0.7.0-rc1 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 b6c66010..cc8cbe50 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.6.0 +require github.com/numaproj/numaflow-go v0.7.0-rc1 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 228bc09b..7588cd91 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.6.0 + github.com/numaproj/numaflow-go v0.7.0-rc1 go.uber.org/atomic v1.11.0 ) diff --git a/pkg/sessionreducer/examples/sum/go.mod b/pkg/sessionreducer/examples/sum/go.mod index c5c31e26..7588cd91 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.6.1-0.20240212202512-715955f1e069 + github.com/numaproj/numaflow-go v0.7.0-rc1 go.uber.org/atomic v1.11.0 ) diff --git a/pkg/sessionreducer/examples/sum/go.sum b/pkg/sessionreducer/examples/sum/go.sum index ae935bd8..e5697aab 100644 --- a/pkg/sessionreducer/examples/sum/go.sum +++ b/pkg/sessionreducer/examples/sum/go.sum @@ -4,10 +4,6 @@ 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/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069 h1:LBMIrUytoxuZazEnwxo+WPAxjHL1rrVhphTyByLiDYY= -github.com/numaproj/numaflow-go v0.6.1-0.20240212202512-715955f1e069/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1 h1:yY1ZjhfqdxE9H4T9YRff+GJHilv9CJgslWEYfsE/EPo= -github.com/numaproj/numaflow-go v0.6.1-0.20240221033908-7c1198bc89f1/go.mod h1:WoMt31+h3up202zTRI8c/qe42B8UbvwLe2mJH0MAlhI= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= go.uber.org/atomic v1.11.0 h1:ZvwS0R+56ePWxUNi+Atn9dWONBPp/AUETXlHW0DxSjE= diff --git a/pkg/shared/util.go b/pkg/shared/util.go index f7747971..751327d9 100644 --- a/pkg/shared/util.go +++ b/pkg/shared/util.go @@ -19,7 +19,7 @@ const ( func PrepareServer(sockAddr string, infoFilePath string) (net.Listener, error) { // If infoFilePath is not empty, write the server info to the file. if infoFilePath != "" { - serverInfo := &info.ServerInfo{Protocol: info.UDS, Language: info.Go, Version: info.GetSDKVersion()} + serverInfo := &info.ServerInfo{Protocol: info.UDS, Language: info.Go, MinimumClientVersion: info.MinimumClientVersion, Version: info.GetSDKVersion()} if err := info.Write(serverInfo, info.WithServerInfoFilePath(infoFilePath)); err != nil { return nil, err } diff --git a/pkg/sideinput/examples/simple-sideinput/go.mod b/pkg/sideinput/examples/simple-sideinput/go.mod index 449a225c..af8813f2 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.6.0 +require github.com/numaproj/numaflow-go v0.7.0-rc1 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 53d5de3d..c636c68b 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.6.0 + github.com/numaproj/numaflow-go v0.7.0-rc1 ) require ( diff --git a/pkg/sinker/examples/log/go.mod b/pkg/sinker/examples/log/go.mod index 5820da2a..56f5c5f2 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.6.0 +require github.com/numaproj/numaflow-go v0.7.0-rc1 require ( github.com/golang/protobuf v1.5.3 // indirect diff --git a/pkg/sourcer/examples/simple_source/go.mod b/pkg/sourcer/examples/simple_source/go.mod index 75fc81d3..bb865791 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.6.0 + github.com/numaproj/numaflow-go v0.7.0-rc1 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 41b0603d..5c8b307f 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.6.0 +require github.com/numaproj/numaflow-go v0.7.0-rc1 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 949a8d93..2c50f521 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.6.0 + github.com/numaproj/numaflow-go v0.7.0-rc1 github.com/stretchr/testify v1.8.1 )