go-streams
Stream processor library
Provides a lightweight and flexible way to process data streams in Go
A lightweight stream processing library for Go
2k stars
29 watching
159 forks
Language: Go
last commit: about 1 month ago
Linked from 2 awesome lists
aerospikedata-pipelinedata-streametlkafkakafka-streamslow-codenats-streamingpipelinepulsarredisstream-processingstream-processorstreaming-apistreaming-datastreamsthrottlingwebsocketwindowingworkflow
Related projects:
Repository | Description | Stars |
---|---|---|
youthlin/stream | Stream processing library for Go | 90 |
wallaroolabs/wally | A distributed stream processing framework for real-time data reactions | 1,477 |
reugn/async | A collection of concurrent and asynchronous data structures and utilities for efficient programming in Go. | 226 |
gazette/core | Enables teams to build platforms mixing SQL, batch, and real-time streaming processing paradigms | 723 |
keilerkonzept/topk | An implementation of probabilistic data structures for approximate data stream processing | 4 |
lgouellec/streamiz | A .NET library for processing and aggregating stream data from Apache Kafka | 477 |
nodefluent/kafka-streams | A Node.js library implementing Kafka Streams functionality for stream state processing and table representation. | 831 |
thempatel/streamvbyte-simdgo | A Go implementation of Stream VByte compression algorithm leveraging SIMD techniques for improved performance. | 16 |
nerevu/riko | A Python library for analyzing and processing streams of structured data | 1,605 |
primetalk/goio | A generics streaming library for Go inspired by Scala's cats-effect and fs2 libraries | 83 |
maki-nage/makinage | Stream Processing Library and Framework | 38 |
gojek/ziggurat | A framework for building stateless applications on top of Kafka stream processing | 399 |
quixio/quix-streams | A Python framework for real-time data processing on Apache Kafka streams | 1,246 |
nikolaydubina/go-featureprocessing | A Go library for fast and simple feature engineering and machine learning data preprocessing | 121 |
reugn/go-quartz | A minimalistic scheduling library that allows developers to create and manage scheduled jobs with various triggers. | 1,805 |