# reugn/go-streams

A lightweight stream processing library for Go

Repository: https://github.com/reugn/go-streams
Canonical: https://ross.abutalabs.com/products/go-streams
Homepage: https://pkg.go.dev/github.com/reugn/go-streams
Language: Go
License: MIT
License Family: permissive
Topics: stream-processing, pipeline, etl, kafka, data-stream, kafka-streams, streams, redis, pulsar, data-pipeline, streaming-data, stream-processor, aerospike, websocket, nats-streaming, streaming-api, windowing, throttling, low-code, workflow
Last push: 2026-01-14T15:05:35+00:00

## Health v2 (maintenance only)
Score: 58/100 (v2, computed 2026-09-02T17:46:02.011165+00:00)
- activity 62, release rhythm 28, longevity 100
- inputs: {"age_days": 2682, "days_push": 231, "days_rel": 479, "gap_med": 61.0, "n_releases_24m": 3}
- flags: none
- formula: round(0.45*activity + 0.35*rhythm + 0.20*longevity); archived -> min(score, 10)

## Adoption (not part of the score)
Stars 2170, forks 174 (observed 2026-08-28T04:06:21.658355+00:00)

## What it is
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
- artifact type: library
- maturity: active
- function: streaming, etl, workflow-automation
- domain: big-data, microservices, developer-tools
- platform: go, cross-platform
- tags: stream-processing, data-pipeline, kafka, windowing, dsl, flow-based-programming, data-engineering

## Member repositories
- reugn/go-streams (main) score 58

## Provenance
- Observed fields: from GitHub, fetched 2026-08-28T04:06:21.658355+00:00.
- Health v2: computed from the inputs above; adoption is never an input.
- Inferred fields (summary, facets, guidance): AI-extracted, prompt v1, taxonomy v1, on 2026-08-30T02:49:20.329658+00:00, confidence not recorded.
  - readme: https://github.com/reugn/go-streams (fetched 2026-08-28T04:06:21.658355+00:00, sha 2497e7efcebb)
  - homepage: https://pkg.go.dev/github.com/reugn/go-streams (fetched 2026-08-29T10:29:25.886723+00:00, sha b63d56296f15)
  - site_page: https://pkg.go.dev/about (fetched 2026-08-29T10:29:25.889531+00:00, sha 757852027879)
  - site_page: https://go.dev/project (fetched 2026-08-29T10:29:25.891564+00:00, sha d5ca00bb378b)
- Data as of 2026-08-30T08:39:29.467469+00:00.