All Versions
16
Latest Version
Avg Release Cycle
140 days
Latest Release
390 days ago

Changelog History
Page 1

  • v0.13.0 Changes

    May 11, 2025

    ๐Ÿ”‹ 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

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

  • v0.12.0 Changes

    March 01, 2025

    ๐Ÿ”‹ 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 Changes

    January 08, 2025

    ๐Ÿ”‹ 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 Changes

    January 14, 2024

    โš  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 Changes

    January 07, 2023

    ๐Ÿ”‹ 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 Changes

    October 17, 2022

    ๐Ÿ”‹ 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 Changes

    November 27, 2021

    ๐Ÿ”‹ 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 Changes

    December 20, 2020
    • โž• Add packages documentation
  • v0.6.2 Changes

    December 19, 2020
    • โœ… Require the latest go-streams module in connectors
  • v0.6.0 Changes

    December 19, 2020
    • ๐Ÿ”จ Refactor package structure
    • โž• Add WebSocket connector