Go Streams Versions Save

A lightweight stream processing library for Go

v0.10.0

4 months ago

⚠ 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

1 year ago

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

1 year ago

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

2 years ago

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

3 years ago
  • Add packages documentation

v0.6.2

3 years ago
  • Require the latest go-streams module in connectors

v0.6.0

3 years ago
  • Refactor package structure
  • Add WebSocket connector

v0.5.2

3 years ago
  • Update dependencies
  • Verify implemented flows satisfy the Flow interface

v0.5.1

3 years ago
  • Update dependencies
  • Improve code documentation

v0.5.0

3 years ago
  • Add Aerospike connector
  • Resolve data loss issue in the sliding window flow