v0.5.0

What's Changed

• chore: expose accumulator fields by @vigith in #148
• feat: Support for OnSuccess sink by @vaibhavtiwari33 in #152
• feat: metadata implementations for source, transformer, map and sink by @adarsh0728 in #151
• feat: add reduce streaming by @vigith in #153
• chore: Update cron schedule for sideinput example by @vaibhavtiwari33 in #154
• doc: add more details by @vigith in #155
• chore: expose and export side-input path by @vigith in #156
• test: Implement redis sink in Rust for on-success sink e2e test by @vaibhavtiwari33 in #157
• test: Unit Tests For Examples by @harshithsaiv in #162
• fix: panic handling in batchmap by @adarsh0728 in #161
• chore: bump version from 0.4.0 to 0.5.0 by @vigith in #163

New Contributors

• @vaibhavtiwari33 made their first contribution in #152

Full Changelog: v0.4.0...v0.5.0

v0.4.0

New Features

• Nack Support For Source #136

Breaking Changes

We introduced ServerExtras which exposes the optional with_ settings, like with_socket_file. You will have to import the trait if you were using those methods.

What's Changed

• chore: update makefile by @yhl25 in #131
• chore: improve error handling for batchmap by @404salad in #137
• chore: generalize server to avoid redundant implementations by @vigith in #138
• feat: Nack Support For Source by @yhl25 in #136
• fix: server shutdowns immediately if user's shutdown oneshot is none by @yhl25 in #140
• chore(ci): explicitly add rustfmt and clippy by @vigith in #142
• chore: export a few consts by @vigith in #135
• fix: reduce visibility by @vigith in #145
• chore: reduce more visibility by @vigith in #146
• chore: update packages and bump up version by @vigith in #147

New Contributors

• @404salad made their first contribution in #137

Full Changelog: v0.3.0...v0.4.0

v0.3.0

What's Changed

• feat: Map Streamer by @yhl25 in #109
• feat: Custom Serve Store for integration with any user-defined store by @BulkBeing in #113
• chore: use std time instead of chrono time by @yhl25 in #112
• chore: update examples base image to 1.84 by @yhl25 in #114
• chore: introduce enum for sink response type by @yhl25 in #115
• chore: upgrade tonic to 0.13.0 by @vigith in #117
• fix: client shutting down should not impact the server by @yhl25 in #120
• feat: Session window and Accumulator by @yhl25 in #118
• feat: refactor by @adarsh0728 in #119
• chore: add new examples to CI by @yhl25 in #123
• chore: Create CODEOWNERS by @vigith in #127
• chore: upgrade rust + latest tonic + cargo fmt by @vigith in #126
• chore: use workspace for dependencies by @yhl25 in #128
• chore: support at least last 5 versions of Rust by @vigith in #129
• feat: panic hook to capture stack trace by @adarsh0728 in #125
• chore: panic handling in reduce by @adarsh0728 in #130

New Contributors

• @adarsh0728 made their first contribution in #119

Full Changelog: v0.2.1...v0.3.0

v0.2.1

What's Changed

• chore: Use cargo workspaces by @BulkBeing in #102
• chore: fix sideinput-udf image build by @BulkBeing in #103
• chore: fix image build issues by @BulkBeing in #105
• feat: change Sourcer API to support sources where pending can not be … by @BulkBeing in #106
• chore: bump up version to 0.2.1 by @vigith in #107

Full Changelog: v0.2.0...v0.2.1

v0.2.0

What's Changed

• feat: UDFs and UDSink by @vigith in #1
• chore: reduce example by @vigith in #2
• chore: add example sink by @vigith in #3
• chore: one more map example by @vigith in #4
• chore: contributing guide by @vigith in #5
• chore: migrate to new sink proto by @vigith in #6
• chore: update map to new proto by @vigith in #8
• chore: fix reduce proto by @vigith in #9
• chore: remove function.proto by @vigith in #10
• feat: add Source transform by @vigith in #11
• chore: remove deprecated map/reduce proto by @vigith in #13
• feat: user-defined source by @vigith in #14
• chore: example for user-defined source by @yhl25 in #15
• chore: update examples by @yhl25 in #16
• doc: add user defined source. by @vigith in #17
• feat: side-input by @vigith in #18
• chore: CI with unit tests by @shubhamdixit863 in #21
• chore: sideInput example by @shubhamdixit863 in #22
• feat: add partitions RPC for source by @BulkBeing in #24
• chore: update .gitignore by @vigith in #25
• Remove Datum trait in mapper by @BulkBeing in #28
• feat: improve sink SDK experience by @vigith in #29
• feat: simplified sourcer server API changes by @BulkBeing in #32
• chore: rename pb module name by @vigith in #33
• feat: make sourcetransfomer API simpler by @vigith in #34
• Use UDF specific names for server info file by @BulkBeing in #35
• chore: export proto definitions by @vigith in #37
• chore: simplified reducer and side input api by @yhl25 in #39
• chore: Introducing Factory to Create Reducer by @yhl25 in #40
• chore: Fallback and Headers Support for Custom Sink by @yhl25 in #49
• fix: setting incorrect enum for sink responses by @yhl25 in #50
• feat: Message To Drop Semantics by @shubhamdixit863 in #47
• Added header values by @shubhamdixit863 in #51
• Fixed the utc_from_timestamp method ,added test cases by @shubhamdixit863 in #60
• Event filter test by @shubhamdixit863 in #58
• chore: Incorporate Proto Definition Changes For Reduce by @yhl25 in #52
• chore: add formatting to CI by @vigith in #63
• feat: automate docker build and push + fix broken examples by @ayildirim21 in #62
• feat: upgrade to tonic 0.12 and internally to hyper 1.x by @vigith in #65
• chore: handle panics inside user handlers by @yhl25 in #67
• feat: impl batch map by @kohlisid in #66
• chore: add flatmap example by @kohlisid in #68
• chore: fix simple source by @yhl25 in #69
• chore: add min-numa version to server info by @kohlisid in #70
• chore: update Serverinfo to use struct by @kohlisid in #71
• chore: buffer channels for better performance by @yhl25 in #72
• chore: update to rust 1.80 by @vigith in #74
• chore: update example version by @kohlisid in #75
• chore: publish to crates.io by @vigith in #81
• chore: update dependencies by @vigith in #82
• chore: retrieve sdk version from env by @KeranYang in #83
• feat: Bidirectional Streaming for Source by @yhl25 in #84
• chore: update ubuntu by @vigith in #86
• docs: minor updates on docs and examples by @KeranYang in #87
• fix: add handshake for readFn and ackFn by @yhl25 in #88
• docs: add instructions on minimum numaflow version update by @KeranYang in #89
• feat: bidirectional streaming for udsink by @yhl25 in #90
• fix: invariant on global stream ending is upheld by @vigith in #92
• feat: Bidirectional streaming for source transformer by @BulkBeing in #91
• feat: container-type level version compatibility check by @KeranYang in #94
• feat: Use gRPC Bidirectional Streaming for Map by @yhl25 in #95
• chore: Release pipeline by @BulkBeing in #97
• feat: Unify Batch Map and Unary Map Operations Using a Shared gRPC Protocol by @yhl25 in #98
• chore: Send EOT message after the responses are forwarded from Sink by @yhl25 in #99
• chore: Batch ack requests and sink responses for better performance by @yhl25 in #100
• chore: update release version by @kohlisid in #101

New Contributors

• @vigith made their first contribution in #1
• @yhl25 made their first contribution in #15
• @shubhamdixit863 made their first contribution in #21
• @ayildirim21 made their first contribution in #62
• @kohlisid made their first contribution in #66
• @KeranYang made their first contribution in #83

Full Changelog: https://github.com/numaproj/numaflow-rs/commits/v0.2.0