reugn/go-streams

Health v2 · maintenance only

Adoption not part of the score

2170 stars · 174 forks observed · 2026-08-28

What it is AI-extracted, prompt v1, taxonomy v1, 2026-08-30, confidence not recorded

A lightweight stream processing library for Go offering a concise DSL to build declarative data pipelines from composable sources, flows, and sinks. It includes connectors for Kafka, Redis, Pulsar, NATS, WebSockets, and more, with zero external dependencies in its core module.

Use cases

• build stream processing pipelines in go
• process kafka streams with a lightweight library
• etl data pipelines in go
• windowing and throttling of event streams
• transform and filter data streams with map/filter/reduce
• connect redis or pulsar into a streaming pipeline

When to choose

• you want a dependency-free, lightweight alternative to heavy stream processing frameworks in Go
• you need composable source/flow/sink pipelines with Kafka, Redis, Pulsar, or NATS connectors
• you prefer a declarative DSL for data pipelines

When to avoid

• you need distributed cluster-scale processing like Flink or Spark Streaming
• you need exactly-once processing guarantees or advanced state management
• your project is not in Go

Facets

library · maturity active

streaming etl workflow-automation big-data microservices developer-tools go cross-platform stream-processing data-pipeline kafka windowing dsl flow-based-programming data-engineering

Member repositories

For agents

markdown · JSON · MCP: product_card(name="reugn/go-streams")