numaflow-go icon indicating copy to clipboard operation
numaflow-go copied to clipboard

Numaflow Golang SDK

Results 10 numaflow-go issues
Sort by recently updated
recently updated
newest added

Currently we depend on 3 gRPC specific binaries: `protoc-gen-go`, `protoc-gen-go-grpc` and `protoc`. We manage the version of `protoc-gen-go` and `protoc-gen-go-grpc` in the `go.mod` file. These binaries are installed if they...

In the current setup, this is difficult to test via UT directly. I tried to add the test there but the assert.Panics (which internally uses recover) was not able to...

Generate code coverage for unit tests and upload to codecov.

https://github.com/numaproj/numaflow-go/pull/111#discussion_r1537708110 This should apply to both session reducer and stream reducer.

https://github.com/numaproj/numaflow-go/pull/99#discussion_r1496134777

https://github.com/numaproj/numaflow/pull/1402

Below is the current reduce proto. ``` /** * ReduceResponse represents a response element. */ message ReduceResponse { // FIXME: put all fields(window, EOF) inside of Result. Reference: https://protobuf.dev/programming-guides/api/#dont-include-primitive-types //...

Most of our go SDK examples are depending on an old version of numaflow-go. Should update to the latest.

https://github.com/marketplace/actions/auto-release