go-streams

⚠ 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)

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

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

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

• Add packages documentation

• Require the latest go-streams module in connectors

• Refactor package structure
• Add WebSocket connector

• Update dependencies
• Verify implemented flows satisfy the Flow interface

• Update dependencies
• Improve code documentation

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

• Migrate from Confluent to Sarama kafka client
• Add signal channel to window flows

• Add Apache Pulsar connector
• Add Network connector

• Fix go lint warnings
• Implement Filter flow
• Improve test coverage