All Versions
16
Latest Version
Avg Release Cycle
140 days
Latest Release
430 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