A lightweight Go framework for building stateful, real-time data pipelines. It processes both streams and batches with a declarative API to create scalable data applications, all in pure Go.
active 2025-03-27 → 2026-03-27 (UTC)
Activity over time
Daily event counts in the loaded window
Line chart, 366 days from 2025-03-27 to 2026-03-27. Pushes: 86 total, peak 16 in a day. Pull requests: 26 total, peak 4 in a day. Issues: 16 total, peak 4 in a day. Comments: 63 total, peak 30 in a day. Stars: 12 total, peak 2 in a day.
- Pushes
- Pull requests
- Issues
- Comments
- Stars
Stars, PRs, issues and forks are under-captured in the later part of this window. GH Archive progressively stopped capturing non-push events during 2026 — −95% or worse by the end of the window. Every series here except Pushes fades for that reason, so a decline above reflects the archive, not this repository. Pushes stay reliable throughout, so read them, and the contributor counts derived from them, as the real signal. Data health has the measurements.
Top contributors
Pushes, PRs, issues, reviews and comments — stars and forks excluded, so this is contribution rather than popularity
| Contributor | Contributions | Pushes | PRs | Comments |
|---|---|---|---|---|
| jecsand838 | 114 | 10 | 7 | 44 |
| reggieross | 84 | 50 | 8 | 14 |
| petertoms1 | 18 | 14 | 4 | 0 |
| ndesai96 | 10 | 3 | 3 | 1 |
| maksym-iv-ef | 7 | 5 | 2 | 0 |
| theclapp | 3 | 0 | 0 | 2 |
| kgrubb | 2 | 2 | 0 | 0 |
| veronica-m-ef | 1 | 0 | 0 | 1 |
| veronica-manchola | 1 | 1 | 0 | 0 |
| github-actions[bot] | 1 | 0 | 1 | 0 |
Recent activity
Latest issues, pull requests and releases
- Pull request#45reggieross2025-12-13 20:05
- Releasegithub-actions[bot]2025-09-17 09:35v0.0.12
- Pull request#41github-actions[bot]2025-09-16 18:10
- Pull request#40jecsand8382025-09-16 18:09
- Issue#32reggieross2025-09-11 14:40Fix Windower Data Race
- Issue comment#37veronica-m-ef2025-09-11 13:33Fix: Ensurer timer is stopped and not replaced
- Pull request#38maksym-iv-ef2025-09-11 12:29
- Pull request#38maksym-iv-ef2025-09-11 12:15
- Pull request#37reggieross2025-09-10 20:46
- Pull request#34jecsand8382025-08-29 15:56
- Issue#31reggieross2025-08-29 15:28Decouple partitioning from windowing with generic output types
- Issue comment#31reggieross2025-08-29 15:28Decouple partitioning from windowing with generic output types
- Issue#32jecsand8382025-08-27 18:33Fix Windower Data Race
- Issue comment#31jecsand8382025-08-27 18:25Decouple partitioning from windowing with generic output types
- Issue#19jecsand8382025-08-27 18:24Optimize Sliding Windows with Slice Reuse
- Issue#27jecsand8382025-08-27 18:24Expanded Benchmarks for Pipelines, KeyedDataStreams, and Windowing
- Issue#18jecsand8382025-08-27 18:24Implement Sharded Store
- Pull request#30jecsand8382025-08-27 18:24
- Pull request#30reggieross2025-08-13 15:57
- Pull request#29reggieross2025-08-10 02:49
- Releasereggieross2025-08-07 21:53v0.0.9
- Issue#24reggieross2025-08-06 00:43Implement a broadcast function
- Issue#27jecsand8382025-07-31 22:03Expanded Benchmarks for Pipelines, KeyedDataStreams, and Windowing
- Pull request#26jecsand8382025-07-31 20:51
- Issue#25jecsand8382025-07-31 19:01Implement New Pipelines Type
Totals cover only the window loaded into ClickHouse and count events, not GitHub's lifetime totals — 12 stars here means stars gained during the window, not the repo's star count.