Download Latest Version
v0.13.0 source code.tar.gz (135.5 kB)
Get an email when there's a new version of go-streams
| Name | Modified | Size | Downloads / Week |
|---|---|---|---|
| Parent folder | |||
| README.md | 2025-05-10 | 1.4 kB | |
| v0.13.0 source code.tar.gz | 2025-05-10 | 135.5 kB | |
| v0.13.0 source code.zip | 2025-05-10 | 188.0 kB | |
| Totals: 3 Items | 324.9 kB | 0 | |
Features
- feat(flow): implement rolling fold transformation by @Wkkkkk in https://github.com/reugn/go-streams/pull/162
- feat(flow): add support for allowed lateness in sliding window by @reugn in https://github.com/reugn/go-streams/pull/177
Fixes
- fix(flow)!: sliding window blocks until the first window is elapsed by @reugn in https://github.com/reugn/go-streams/pull/165
- fix(flow): use of sliding window in keyed flow by @reugn in https://github.com/reugn/go-streams/pull/176
Improvements
- refactor(flow): use atomic.Int64 in Throttler by @reugn in https://github.com/reugn/go-streams/pull/169
- refactor(flow): rework parallel processing of stream elements by @reugn in https://github.com/reugn/go-streams/pull/178
Connectors
- deps(connectors): update dependency versions by @reugn in https://github.com/reugn/go-streams/pull/183
Maintenance
- chore: update code documentation and rework the maze example by @reugn in https://github.com/reugn/go-streams/pull/167
- docs(flow): enhance keyed flow documentation by @reugn in https://github.com/reugn/go-streams/pull/181
- ci: upgrade golangci-lint to v2.1.5 by @reugn in https://github.com/reugn/go-streams/pull/182
New Contributors
- @Wkkkkk made their first contribution in https://github.com/reugn/go-streams/pull/162
Full Changelog: https://github.com/reugn/go-streams/compare/v0.12.0...v0.13.0