go-streams

Stream processor library

Provides a lightweight and flexible way to process data streams in Go

A lightweight stream processing library for Go

GitHub

2k stars
28 watching
157 forks
Language: Go
last commit: 12 days ago
Linked from 2 awesome lists

aerospikedata-pipelinedata-streametlkafkakafka-streamslow-codenats-streamingpipelinepulsarredisstream-processingstream-processorstreaming-apistreaming-datastreamsthrottlingwebsocketwindowingworkflow

Backlinks from these awesome lists:

Related projects:

Repository Description Stars
youthlin/stream Stream processing library for Go 89
wallaroolabs/wally A distributed stream processing framework for real-time data reactions 1,480
reugn/async A collection of concurrent and asynchronous data structures and utilities for efficient programming in Go. 224
gazette/core Enables teams to build platforms mixing SQL, batch, and real-time streaming processing paradigms 718
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 469
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,604
primetalk/goio A generics streaming library for Go inspired by Scala's cats-effect and fs2 libraries 82
maki-nage/makinage Stream Processing Library and Framework 39
gojek/ziggurat A framework for building stateless applications on top of Kafka stream processing 398
quixio/quix-streams A Python framework for real-time data processing on Apache Kafka streams 1,190
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,793