v0.13.0

Features

• feat(flow): implement rolling fold transformation by @Wkkkkk in #162
• feat(flow): add support for allowed lateness in sliding window by @reugn in #177

Fixes

• fix(flow)!: sliding window blocks until the first window is elapsed by @reugn in #165
• fix(flow): use of sliding window in keyed flow by @reugn in #176

Improvements

• refactor(flow): use atomic.Int64 in Throttler by @reugn in #169
• refactor(flow): rework parallel processing of stream elements by @reugn in #178

Connectors

• deps(connectors): update dependency versions by @reugn in #183

Maintenance

• chore: update code documentation and rework the maze example by @reugn in #167
• docs(flow): enhance keyed flow documentation by @reugn in #181
• ci: upgrade golangci-lint to v2.1.5 by @reugn in #182

New Contributors

• @Wkkkkk made their first contribution in #162

Full Changelog: v0.12.0...v0.13.0

v0.12.0

Features

• feat!: introduce AwaitCompletion method to Sink by @reugn in #154
• feat(flow): implement ZipWith stream transformation by @reugn in #156
• feat!: rework standard connector implementations by @reugn in #157

Connectors

• deps(connectors): update dependency versions by @reugn in #152

Maintenance

• chore: reorganize the extension package by @reugn in #155
• docs(contributing): update minimum go version requirement by @reugn in #159
• ci: update golangci-lint configuration by @reugn in #161

Full Changelog: v0.11.0...v0.12.0

v0.11.0

Features

• feat(flow): add keyed flow implementation by @reugn in #141

Fixes

• fix(flow): remove priority queue from sliding window by @reugn in #137

Improvements

• refactor(flow): hide mutex methods in window flows by @reugn in #138

Connectors

• deps: upgrade dependencies in connectors by @reugn in #114
• refactor(aerospike)!: enhance connector functionality by @reugn in #127
• feat(websocket)!: rename the connector module by @reugn in #129
• feat(connectors)!: remove signal.Notify from connectors by @reugn in #131
• refactor(redis): minor connector improvements by @reugn in #132
• fix(connectors): string formatting for message type by @reugn in #134
• feat(connectors)!: use slog for structured logging by @reugn in #140
• feat: add support for AWS S3 connector by @reugn in #143
• chore(aws): refine S3 connector logs by @reugn in #145
• feat: add support for GCP Storage connector by @reugn in #146
• feat: add support for Azure Blob Storage connector by @reugn in #147

Maintenance

• test: improve code coverage by @reugn in #113
• chore: add gci linter by @reugn in #128
• chore(examples): update docker compose files by @reugn in #133
• test(flow): improve coverage and minor refactoring by @reugn in #139
• ci: update golangci-lint configuration by @reugn in #148

Full Changelog: v0.10.0...v0.11.0

v0.10.0

⚠ BREAKING CHANGES

• refactor!: replace uint parameter type with int; panic on invalid argument (#107)
• feat!: make window and batch flows generic (#104)

Features

• feat: implement batch with timeout flow (#103)

Fixes

• fix: session window inactivity timer reset mechanism (#102)
• fix: throttler functionality; improve code coverage (#101)
• fix: use ticker time in sliding window (#100)
• fix: close output channel properly in window flows (#99)

Improvements

• refactor: make utility packages internal (#108)
• refactor: replace empty interface with any (#105)
• refactor: pre-allocate slice in flow.FanOut (#94)

Connectors

• feat: implement Redis stream connector (#80)
• refactor!: JetStream source and sink connectors (#109)
• refactor!: Redis publish-subscribe connector (#79)
• build: upgrade dependencies in connectors (#82)

Maintenance

• docs: improve code documentation (#106)
• ci: update action versions in workflows (#110)

v0.9.0

Features

• Make SlidingWindow generic
• Validate constructor parameters in SlidingWindow
• Make the Split utility function generic

Fixes

• Fix the SlidingWindow element assignment mechanism

Improvements

• Add go1.18 to the CI build workflow
• Improve test coverage

v0.8.0

Features

• Use generic transformation functions in Flows (#53)
• Implement RoundRobin Flow (#38)
• Implement Reduce Flow (#53)
• Implement Flatten Flow (#53)
• Require go 1.18

Fixes

• Close the notify channel in Throttler (#41)
• Fix sliding window emit bug (#50)

Improvements

• Update GitHub actions versions
• Remove deprecated linters

v0.7.0

Features

• Implement Session Window flow
• Update module dependencies

Fixes

• Fix potential memory leak related to using time.After
• Remove Mutex in Throttler
• Fix minor bugs in connectors

Improvements

• Migrate from Travis CI to GitHub Actions
• Improve code documentation

v0.6.3

• Add packages documentation

v0.6.2

• Require the latest go-streams module in connectors

v0.6.0

• Refactor package structure
• Add WebSocket connector