- 48aad5f Update manifests to v0.6.0
- 09ce54f fix(autoscaling): Ack pending should be included in total pending calculation (#212)
- 9922787 fix(autoscaling): Skip autoscaling if vertex is not in running phase (#207)
- bc2380a feat: ISBSVC add support for redis cluster mode (#195)
- 72a96a5 refactor: move controllers package to pkg/reconciler (#192)
- b1b78fa fix: update udf fetchWatermark and publishWatermark initial values (#193)
- d491260 fix(docs): readme for UI development (#181)
- 6b121c6 feat: grpc udsink (#174)
- 567da7b fix: numaflow-go udf example & docs (#177)
- 4652f80 fix: use scale.max if it is set (#179)
- 900314b fix broken path (#176)
- 3b02f2a feat: Shuffle implementation (#169)
- 021bb9d feat: windowing operations (#157)
- 7d41129 feat: watermark for sources (#159)
- 5f5b2df fix: daemon service client memory leak (#161)
- bfe9669 pbq implementation (#155)
- 8dfedd8 feat: check if udf is running in liveness probe (#156)
- 81e76d8 feat: Add udf grpc support Fixes #145 (#146)
- 511faff refactor: some refactor on watermark (#149)
- 7fe40c4 fix: Fixed JS bug (#144)
- 24a16a0 bug: watermark needs nil check
- f4ed831 fix: pipeline UI broken when vertex scaling down to 0 (#132)
- 0ae0377 feat: JetStream auto-reconnection (#127)
- 2fc04eb feat: Add watermark for sink vertex (#124)
- d958ee6 feat: autoscaling with back pressure factor (#123)
- b1f7768 feat: add watermark to UI (#122)
- 7feeaa8 feat: add processing rate to UI (#121)
- 43fae93 feat: Expose watermark over HTTP (#120)
- ec02304 fix: daemon service rest api not working (#119)
- f3da56d chore(deps): bump terser from 5.14.1 to 5.14.2 in /ui (#117)
- e2e63c8 feat: Numaflow autoscaling (#115)
- e5da3f5 feat: watermark for headoffset (#116)
- a45b2ee feat: support namespace scope installation (#112)
- ce39199 feat: Expose ReadTimeoutSeconds on Vertex (#110)
- 18ad1c5 fix: imagepullpocily for local testing (#113)
- 469849b feat: removed udfWorkers from limits and added some docs (#103)
- 3fada66 feat: Add icon and other minor changes (#94)
- a81838d feat: end to end tickgen watermark validation (#98)
- d7d9317 fix: Broken hyperlink (#96)
- a2e0792 add no-op KV Store (#91)
- 45c8cb6 feat: no operation watermark progressor (#90)
- 448c229 feat: kafka source pending messages (#80)
- 1aa3930 feat: Interface for Watermark (#82)
- be78c52 feat: expose pending messages and processing rate (#79)
- df30f2a feat: Added the right way to decipher from and to vertex (#78)
- 639c459 feat: define buffer limits on edges (#70)
- 41fdd38 feat: Merge UX server code (#67)
- ced9907 feat: auto-scaling (part 1) (#59)
- fd5b374 Added name to service spec (#58)
- dc2badf feat: introduce source buffer and sink buffer (#53)
- 4ed83a2 feat: async publishing for kafka sink (#51)
- 9f9f5ba fix spelling errors (#48)
- f423002 feat: controller to create buckets (#47)
- 8328739 turn on watermark only if ENV value is true (#46)
- 46f72e2 minimal end to end line-graph watermark integration (#43)
- 1f8203f Fixed spelling error (#44)
- f1e99ea Exponential buckets (#42)
- dfcfdeb fix: different behavior for time.After in go 1.18 (#39)
- Chrome
- Derek Wang
- Juanlu Yu
- Krithika3
- Qianbo Huai
- Saravanan Balasubramanian
- Sidhant Kohli
- Vigith Maurice
- Yashash H L
- dependabot[bot]
- ac15d22 Update manifests to v0.5.6
- f236375 feat: grpc udsink (#174)
- 2650c2d fix: numaflow-go udf example & docs (#177)
- c44f733 fix: use scale.max if it is set (#179)
- 39e92d0 fix broken path (#176)
- 46ce0f8 feat: Shuffle implementation (#169)
- 71ca00a feat: windowing operations (#157)
- ca00b78 feat: watermark for sources (#159)
- 91e21ce pbq implementation (#155)
- 6542400 feat: check if udf is running in liveness probe (#156)
- 79dce0b feat: Add udf grpc support Fixes #145 (#146)
- Chrome
- Derek Wang
- Juanlu Yu
- Vigith Maurice
- Yashash H L
- 9aae638 Update manifests to v0.5.5
- 3241432 fix: daemon service client memory leak (#161)
- be47a26 refactor: some refactor on watermark (#149)
- 857cce7 fix: Fixed JS bug (#144)
- da16abc bug: watermark needs nil check
- c9998a1 fix: pipeline UI broken when vertex scaling down to 0 (#132)
- Derek Wang
- Krithika3
- Vigith Maurice
- 57513b4 Update manifests to v0.5.4
- 94cdb82 feat: JetStream auto-reconnection (#127)
- 8d83540 feat: Add watermark for sink vertex (#124)
- 228ba32 feat: autoscaling with back pressure factor (#123)
- 9833efd feat: add watermark to UI (#122)
- 0dab55d feat: add processing rate to UI (#121)
- ffd38a1 feat: Expose watermark over HTTP (#120)
- c09502a fix: daemon service rest api not working (#119)
- ebc10f4 chore(deps): bump terser from 5.14.1 to 5.14.2 in /ui (#117)
- 84490ca feat: Numaflow autoscaling (#115)
- 32b9848 feat: watermark for headoffset (#116)
- 283dae9 feat: support namespace scope installation (#112)
- 8e612b1 feat: Expose ReadTimeoutSeconds on Vertex (#110)
- d95d41b fix: imagepullpocily for local testing (#113)
- Derek Wang
- Krithika3
- Saravanan Balasubramanian
- Sidhant Kohli
- Vigith Maurice
- dependabot[bot]
- efee544 Update manifests to v0.5.3
- 5895fac feat: removed udfWorkers from limits and added some docs (#103)
- 0b75495 feat: Add icon and other minor changes (#94)
- 7eb08f5 feat: end to end tickgen watermark validation (#98)
- 3338e65 fix: Broken hyperlink (#96)
- e311222 add no-op KV Store (#91)
- 5d2f90e feat: no operation watermark progressor (#90)
- f58d0f4 feat: kafka source pending messages (#80)
- cbb16ca feat: Interface for Watermark (#82)
- 5592bb1 feat: expose pending messages and processing rate (#79)
- 06a3df2 feat: Added the right way to decipher from and to vertex (#78)
- a0908ad feat: define buffer limits on edges (#70)
- a1d3639 feat: Merge UX server code (#67)
- 571c48e feat: auto-scaling (part 1) (#59)
- 1e0384b Added name to service spec (#58)
- Derek Wang
- Krithika3
- Sidhant Kohli
- Vigith Maurice
- 2f2d10c Update manifests to v0.5.2
- cedd0d1 feat: introduce source buffer and sink buffer (#53)
- d3301aa feat: async publishing for kafka sink (#51)
- 2474eb8 fix spelling errors (#48)
- c4a12f8 feat: controller to create buckets (#47)
- eb97dc3 turn on watermark only if ENV value is true (#46)
- f189ba3 minimal end to end line-graph watermark integration (#43)
- Derek Wang
- Qianbo Huai
- Vigith Maurice
- bb9be80 Update manifests to v0.5.1
- 912747e Fixed spelling error (#44)
- 3aeb33a Exponential buckets (#42)
- 1d65682 fix: different behavior for time.After in go 1.18 (#39)
- Derek Wang
- Krithika3