Get real-time insights from all types of time series data with InfluxDB. Ingest, query, and analyze billions of data points in real-time with unbounded cardinality. Learn more →
Top 17 Go Stream Processing Projects
-
-
I’ve successfully worked on projects using an asynchronous event-driven way of connecting services. I really like the decoupling of business logic and the events triggering it. I highly recommend https://github.com/ThreeDotsLabs/watermill to be more flexible when it comes to choosing the actual technology driving the async patter. It might be NATS today but requirements might change and you need to change. Watermill prepares you for this.
-
WorkOS
The modern identity platform for B2B SaaS. The APIs are flexible and easy-to-use, supporting authentication, user identity, and complex enterprise features like SSO and SCIM provisioning.
-
-
Project mention: FireScroll - An unkillable multi-region KV database that scales reads to infinity | /r/golang | 2023-05-01
I have used HTTP3 QUIC for really fast edge. This golang project: https://github.com/yomorun/yomo
-
peerdb
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage
Project mention: Pgwire: a Rust library for PostgreSQL compatible application | news.ycombinator.com | 2024-03-20We at PeerDB (https://github.com/PeerDB-io/peerdb) were early adopters of Pgwire to implement our Postgres-compatible SQL Layer to do ETL. Very easy to work with. Saved us multiple months of effort to build it from scratch.
-
If you happen to be putting together a platform then look at Gazette. We use it to read/write streaming data into nice and orderly "fragment files" in cloud storage. It provides excellent durability guarantees and turns out to be an extremely efficient way to handle both reads and writes of streaming data. Readers get handed out pre-signed cloud storage URLs that are fetched by the client, and writes are batched into time and/or size bounded "fragments" that are durably replicated until being uploaded into cloud storage.
-
-
InfluxDB
Power Real-Time Data Analytics at Scale. Get real-time insights from all types of time series data with InfluxDB. Ingest, query, and analyze billions of data points in real-time with unbounded cardinality.
-
gostream
A Go port of the Java Streams API. Type-safe and functional Go Streams processing for Go 1.18+.
-
-
-
-
csvplus
csvplus extends the standard Go encoding/csv package with fluent interface, lazy stream operations, indices and joins.
-
-
stream
stream is a concurrency pattern implementation using Go generics. a.k.a. my accidentally awesome library (by devnw)
-
Built something similar in Go with a friend a few years ago.
-
-
-
SaaSHub
SaaSHub - Software Alternatives and Reviews. SaaSHub helps you find the best software and product alternatives
Go Stream Processing related posts
- Hummock: A Storage Engine Designed for Stream Processing
- Fancy stream processing made operationally mundane
- Lakehouse - event data
- Benthos: Fancy stream processing made operationally mundane
- Benthos: Open-source stream processing tool
- Simple Change Data Capture (CDC) using AWS DynamoDB
- Go in depth youtube channels?
-
A note from our sponsor - InfluxDB
www.influxdata.com | 18 Apr 2024
Index
What are some of the best open-source Stream Processing projects in Go? This list will help you:
Project | Stars | |
---|---|---|
1 | Benthos | 7,516 |
2 | watermill | 6,697 |
3 | go-streams | 1,746 |
4 | yomo | 1,607 |
5 | peerdb | 1,595 |
6 | core | 516 |
7 | function-mesh | 208 |
8 | gostream | 146 |
9 | machine | 142 |
10 | stream | 85 |
11 | goio | 78 |
12 | csvplus | 66 |
13 | vaero | 65 |
14 | stream | 63 |
15 | styx | 60 |
16 | turbine-go | 16 |
17 | go-bench-stream | 0 |