Flin is a fast, distributed data engine built in Go, designed to handle key-value storage, message queues, and streaming workloads — all under one unified system. It’s powered by BadgerDB for persistence, and ClusterKit for clustering and coordination.

Stream processing using Cloud PubSub and Dataflow SQL in BigQuery

Worker service that provides an API to run Linux processes.

Reflex stream client for redis streams

declarative, generic, and context aware interface for streaming io.Reader's of json and csv content with optional concurrency

Easily share and organize your IPTV account limited to 1 device. Multiplex live channel to several clients without being ban by provider. Enjoy Discord integration that ease the download of VOD contents.

Go channels as streams.

Watch TV Show / Movies with cli

Go-powered API example using Cassandra

Multi-casting capable event subscription library

Go e Kinesis stream

简单、实用的Golang Stream流操作，支持泛型。

JSON File

Kafka Processing Library for Golang

Go template lister and renderer. Render templates on the fly by passing variables as flags or streaming JSON from stdin to rendering an array of objects.

golang java style stream

一个嵌入stream依赖的golang库(A golang library with embedded stream dependencies)

MQTT client that creates a data stream using two topics

Streaming kafka messages from one topic to other

utility library with different implementations of I/O primitives for various common tasks