An open API service providing package, version and dependency metadata of many open source software ecosystems and registries.

proxy.golang.org "stream-processing" keyword

github.com/kenju/go-pipeline v0.2.6
concurrent stream-processing library in Go
13 versions - Latest release: about 7 years ago - 1 dependent repositories - 3 stars on GitHub
Top 6.0% on proxy.golang.org
github.com/whitaker-io/machine/v3 v3.2.4 💰
Package machine - Copyright © 2020 Jonathan Whitaker <github@whitaker.io>. Use of this source co...
18 versions - Latest release: almost 2 years ago - 1 dependent repositories - 163 stars on GitHub
Top 5.8% on proxy.golang.org
github.com/svenvdam/linea/connectors/aws v0.1.0
A type-safe and composable stream processing library for Go
1 version - Latest release: 10 months ago - 0 stars on GitHub
Top 4.5% on proxy.golang.org
github.com/ThreeDotsLabs/watermill/tools/mill v0.0.0-20231004174515-d20a60514568
Building event-driven applications the easy way in Go.
18 versions - Latest release: over 2 years ago - 8,860 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/NeutrinoCorp/gluon v0.3.7
:sparkler: A composable message bus for Event-Driven systems written in Go.
16 versions - Latest release: about 4 years ago - 2 stars on GitHub
Top 0.8% on proxy.golang.org
github.com/ThreeDotsLabs/watermill v1.5.1
Watermill is a Golang library for working efficiently with message streams. It is intended for b...
53 versions - Latest release: 6 months ago - 429 dependent packages - 271 dependent repositories - 8,860 stars on GitHub
Top 9.7% on proxy.golang.org
github.com/samsara/samsara v0.0.0-20191110193549-238d050b392e
Samsara is a real-time analytics platform
1 version - Latest release: over 6 years ago - 142 stars on GitHub
Top 1.3% on proxy.golang.org
github.com/Jeffail/benthos/v3 v3.65.0 💰
Fancy stream processing made operationally mundane
99 versions - Latest release: almost 4 years ago - 13 dependent packages - 9 dependent repositories - 5,851 stars on GitHub
Top 0.9% on proxy.golang.org
github.com/francoispqt/gojay v1.2.13
Package gojay implements encoding and decoding of JSON as defined in RFC 7159. The mapping betwee...
4 versions - Latest release: over 6 years ago - 2,386 dependent packages - 5,309 dependent repositories - 2,060 stars on GitHub
Top 9.5% on proxy.golang.org
github.com/qntfy/frinesis v0.1.1
Frizzle for AWS Kinesis
3 versions - Latest release: about 7 years ago - 1 dependent package - 1 dependent repositories - 2 stars on GitHub
Top 9.4% on proxy.golang.org
github.com/numaproj/numalogic-prometheus/prometheus-query-service
AIOps for metrics in Prometheus
Latest release: about 1 month ago - 27 stars on GitHub
github.com/findcoo/stream v0.0.0-20171031012444-171658ae008b
make simple ReactiveX pattern for golang
1 version - Latest release: over 8 years ago - 1 dependent repositories - 3 stars on GitHub
Top 1.7% on proxy.golang.org
github.com/yomorun/yomo v1.21.2 💰
🦖 Serverless AI Agent Framework with Geo-distributed Edge AI Infra.
139 versions - Latest release: 11 days ago - 13 dependent packages - 20 dependent repositories - 1,847 stars on GitHub
Top 1.4% on proxy.golang.org
github.com/benthosdev/benthos/v4 v4.81.0 💰
Fancy stream processing made operationally mundane
180 versions - Latest release: 5 days ago - 36 dependent packages - 9 dependent repositories - 5,853 stars on GitHub
Top 5.5% on proxy.golang.org
github.com/project-flogo/stream/activity/filter v0.2.0
Elegant stream processing pipeline written entirely in Golang
1 version - Latest release: almost 7 years ago - 66 stars on GitHub
Top 1.3% on proxy.golang.org
github.com/redpanda-data/redpanda/src/go/rpk v0.0.0-20260211130810-18fbe0610018
Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKee...
2,085 versions - Latest release: 13 days ago - 4 dependent packages - 25 dependent repositories - 11,181 stars on GitHub
github.com/neutrinocorp/gluon v0.3.7
:sparkler: A composable message bus for Event-Driven systems written in Go.
16 versions - Latest release: about 4 years ago - 1 dependent repositories - 2 stars on GitHub
Top 3.5% on proxy.golang.org
github.com/numaproj/numaflow v1.7.2
Kubernetes-native platform to run massively parallel data/streaming jobs
80 versions - Latest release: 10 days ago - 1 dependent package - 2 dependent repositories - 2,346 stars on GitHub
Top 7.2% on proxy.golang.org
github.com/meroxa/turbine-go v1.0.1
Turbine Library for Go
2 versions - Latest release: over 3 years ago - 1 dependent package - 2 dependent repositories - 13 stars on GitHub
Top 9.8% on proxy.golang.org
github.com/meroxa/turbine-go/v3 v3.0.1
Turbine Library for Go
2 versions - Latest release: about 2 years ago - 14 stars on GitHub
Top 7.6% on proxy.golang.org
github.com/rafiulhc/grpc-blockchain-endpoints v0.0.0-20220920080551-0ad3c435eef5
1 version - Latest release: over 3 years ago - 0 stars on GitHub
Top 8.1% on proxy.golang.org
github.com/spy16/fusion v0.3.2
💥 Fusion is a tiny stream processing library written in Go.
16 versions - Latest release: about 5 years ago - 1 dependent package - 1 dependent repositories - 17 stars on GitHub
Top 9.6% on proxy.golang.org
github.com/meroxa/turbine-go/v2 v2.1.3
Turbine Library for Go
7 versions - Latest release: over 2 years ago - 14 stars on GitHub
Top 6.3% on proxy.golang.org
github.com/devnw/stream v1.2.0 💰
Stream is a generic implementation for concurrency communication patterns
12 versions - Latest release: about 2 years ago - 57 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/simon-xia/fuzzyQuantile v0.0.0-20170810125847-0f2b52ae985e
Package fuzzyQuantile is a high performance quantile estimation(e.g. 90th, 95th, 99th) of streami...
1 version - Latest release: over 8 years ago - 3 stars on GitHub
Top 5.6% on proxy.golang.org
github.com/lpgauth/swirl v0.2.3
High-Performance Erlang Stream Processor
9 versions - Latest release: over 11 years ago - 58 stars on GitHub
Top 6.7% on proxy.golang.org
github.com/online-ml/river v1.2.3 💰
🌊 Online machine learning in Python
1 version - Latest release: over 3 years ago - 5,568 stars on GitHub
Top 4.6% on proxy.golang.org
github.com/reugn/go-streams/redis v0.1.2
Package redis implements the Redis Pub/Sub connector.
3 versions - Latest release: about 5 years ago - 1 dependent repositories - 1,356 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/bytedance/elkeid-hub v1.0.1
Elkeid HUB is a rule/event processing engine maintained by the Elkeid Team that supports streamin...
1 version - Latest release: about 4 years ago - 99 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/project-flogo/stream/service/telemetry v0.0.0-20230615163402-7e39aad48346
Elegant stream processing pipeline written entirely in Golang
3 versions - Latest release: over 2 years ago - 66 stars on GitHub
Top 10.0% on proxy.golang.org
github.com/numaproj/numalogic-prometheus v0.7.0
AIOps for metrics in Prometheus
37 versions - Latest release: about 2 years ago - 27 stars on GitHub
Top 6.9% on proxy.golang.org
github.com/maxhalford/line
:fish: A streaming ETL for fish
Latest release: 4 months ago - 13 stars on GitHub
Top 4.4% on proxy.golang.org
github.com/benthosdev/benthos v1.20.4 💰
Fancy stream processing made operationally mundane
295 versions - Latest release: almost 7 years ago - 5,853 stars on GitHub
Top 4.5% on proxy.golang.org
github.com/ThreeDotsLabs/watermill/docs/content/docs/snippets/tail-log-file
Building event-driven applications the easy way in Go.
Latest release: 3 months ago - 8,860 stars on GitHub
Top 7.8% on proxy.golang.org
github.com/itsubaki/gostream-server v0.0.0-20230312010818-05d258f2dfd6
Stream Processing Server written in golang
3 versions - Latest release: almost 3 years ago - 7 stars on GitHub
Top 7.2% on proxy.golang.org
github.com/im-kulikov/xml-test-task
XML Test task
Latest release: 5 months ago - 0 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/francoispqt/goJay v1.2.13
Package gojay implements encoding and decoding of JSON as defined in RFC 7159. The mapping betwee...
4 versions - Latest release: over 6 years ago - 2,066 stars on GitHub
Top 4.1% on proxy.golang.org
github.com/fluent/fluent-bit v3.2.2+incompatible
Fast and Lightweight Logs, Metrics and Traces processor for Linux, BSD, OSX and Windows
241 versions - Latest release: about 1 year ago - 7,322 stars on GitHub
Top 6.3% on proxy.golang.org
github.com/ThreeDotsLabs/watermill/tools/pq
Building event-driven applications the easy way in Go.
Latest release: about 2 months ago - 9,105 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/denkhaus/nksh v0.0.0-20190313093604-8923af619569
Neo4j-Kafka-Stream-Handler
1 version - Latest release: almost 7 years ago - 1 stars on GitHub
Top 1.5% on proxy.golang.org
github.com/Jeffail/benthos v1.20.4 💰
Fancy stream processing made operationally mundane
295 versions - Latest release: almost 7 years ago - 8 dependent packages - 6 dependent repositories - 5,851 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/benthosdev/benthos/v3 v3.65.0 💰
Fancy stream processing made operationally mundane
99 versions - Latest release: almost 4 years ago - 8,138 stars on GitHub
Top 3.6% on proxy.golang.org
github.com/google/mediapipe v0.10.18
Cross-platform, customizable ML solutions for live and streaming media.
47 versions - Latest release: over 1 year ago - 1 dependent repositories - 20,991 stars on GitHub
Top 5.6% on proxy.golang.org
go.atomizer.io/stream v1.2.0 💰
Package stream provides a set of generic functions for working concurrent design patterns in Go. ...
11 versions - Latest release: about 2 years ago - 2 dependent packages - 3 dependent repositories - 63 stars on GitHub
github.com/kmgreen2/agglo
Agglo: A Process-Anywhere Framework for Event Stream Processing
Latest release: 3 months ago - 2 stars on GitHub
Top 2.0% on proxy.golang.org
github.com/reugn/go-streams v0.13.0
Package streams specifies interfaces to be implemented by the streaming connectors and operators.
17 versions - Latest release: 10 months ago - 11 dependent packages - 4 dependent repositories - 1,653 stars on GitHub
Top 5.8% on proxy.golang.org
github.com/elastiflow/pipelines v0.0.13
Package pipelines provides a set of utilities for creating and managing concurrent data processin...
13 versions - Latest release: 5 months ago - 6 stars on GitHub
Top 8.6% on proxy.golang.org
github.com/dinorain/depositaja v0.0.0-20220803170445-3e85c9219771
A fictitious service where user can deposit into their wallet and fetch their current balance usi...
1 version - Latest release: over 3 years ago - 0 stars on GitHub
Top 6.5% on proxy.golang.org
github.com/qntfy/frizzle v0.5.2
The magic message bus
3 versions - Latest release: almost 7 years ago - 2 dependent packages - 3 dependent repositories - 15 stars on GitHub
Top 6.3% on proxy.golang.org
github.com/google-ai-edge/mediapipe v0.10.32
Cross-platform, customizable ML solutions for live and streaming media.
55 versions - Latest release: about 1 month ago - 31,555 stars on GitHub
Top 4.5% on proxy.golang.org
github.com/ThreeDotsLabs/watermill/dev/validate-examples v0.0.0-20230716085306-43d9a13d1ed0
Building event-driven applications the easy way in Go.
7 versions - Latest release: over 2 years ago - 8,860 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/blendle/pg2kafka v0.0.0-20210623111042-e758639c4af5
Ship changes in Postgres 🐘 to Kafka 📖
1 version - Latest release: over 4 years ago - 69 stars on GitHub
github.com/artyomturkin/go-stream v1.1.2
Common stream abstraction and in-memory implementation for streaming data
6 versions - Latest release: almost 7 years ago - 1 dependent package - 1 dependent repositories - 0 stars on GitHub
Top 5.9% on proxy.golang.org
github.com/logrange/logrange v0.1.48
High performance data aggregating storage
12 versions - Latest release: about 5 years ago - 1 dependent repositories - 192 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/monasca/monasca-aggregator v0.0.0-20180221182304-95b71d7012cf
Near real-time continuous aggregation of Monasca metrics
1 version - Latest release: about 8 years ago - 11 stars on GitHub
Top 5.5% on proxy.golang.org
github.com/kurrent-io/kurrentDB-Client-Go v1.1.1
KurrentDB Go Client
4 versions - Latest release: 3 months ago - 6 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/talariadb/talaria v1.6.1
TalariaDB is a distributed, highly available, and low latency time-series database for Presto
37 versions - Latest release: over 2 years ago - 225 stars on GitHub
Top 4.6% on proxy.golang.org
github.com/reugn/go-streams/kafka v0.1.2
Package kafka implements the Apache Kafka connector.
3 versions - Latest release: about 5 years ago - 1 dependent repositories - 1,356 stars on GitHub
Top 6.2% on proxy.golang.org
github.com/reugn/go-streams/azure
Package azure implements streaming connectors for Microsoft Azure services.
Latest release: 3 months ago - 1,910 stars on GitHub
Top 4.3% on proxy.golang.org
github.com/whitaker-io/machine v1.1.0 💰
Package machine - Copyright © 2020 Jonathan Whitaker <github@whitaker.io>. Use of this source co...
167 versions - Latest release: almost 4 years ago - 13 dependent packages - 163 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/vsouza/go-kafka-example v0.0.0-20191022175448-d9993900eb33
Golang Kafka consumer and producer example
1 version - Latest release: over 6 years ago - 172 stars on GitHub
Top 4.8% on proxy.golang.org
github.com/mariomac/gostream v0.10.1
A Go port of the Java Streams API. Type-safe and functional Go Streams processing
5 versions - Latest release: 6 months ago - 2 dependent packages - 3 dependent repositories - 167 stars on GitHub
Top 9.6% on proxy.golang.org
github.com/neutrinocorp/streams v0.2.6
Package streams is a toolkit crafted for data-in-motion ecosystems written in Go.
13 versions - Latest release: almost 4 years ago - 1 dependent package - 1 dependent repositories - 3 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/JoshKCarroll/frizzle
The magic message bus
Latest release: almost 2 years ago - 15 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/mh-cbon/plumber v0.0.0-20170429133309-f14b49bad5eb
Package plumber builds pipes to transform a data stream.
1 version - Latest release: almost 9 years ago - 4 stars on GitHub
Top 6.1% on proxy.golang.org
github.com/maxim2266/csvplus v0.5.0
Package csvplus extends the standard Go encoding/csv package with fluent interface, lazy stream p...
11 versions - Latest release: 10 months ago - 1 dependent package - 2 dependent repositories - 67 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/MaterializeInc/materialize v26.5.1+incompatible
Real-time Data Integration and Transformation: use SQL to transform, deliver, and act on fast-cha...
706 versions - Latest release: 2 months ago - 6,153 stars on GitHub
Top 8.1% on proxy.golang.org
github.com/neutrinoCorp/streams v0.2.6
:envelope: Streams is a toolkit crafted for data-in-motion ecosystems written in Go.
13 versions - Latest release: almost 4 years ago - 6 stars on GitHub
Top 6.2% on proxy.golang.org
github.com/reugn/go-streams/gcp
Package gcp implements streaming connectors for Google Cloud Platform.
Latest release: 2 months ago - 1,910 stars on GitHub
Top 9.4% on proxy.golang.org
github.com/ostafen/hermes
EventStoreDB-like stream projections on top of Apachi Kafka.
Latest release: 5 months ago - 2 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/qntfy/frafka v0.4.0
Frizzle for Apache Kafka
9 versions - Latest release: about 5 years ago - 13 stars on GitHub
Top 8.4% on proxy.golang.org
github.com/mvbrock/clusterizer
A scalable streaming cluster analysis command line tool
Latest release: about 1 month ago - 0 stars on GitHub
Top 5.1% on proxy.golang.org
github.com/schollz/pluck v1.1.3
Pluck text in a fast and intuitive way :rooster:
6 versions - Latest release: over 8 years ago - 1 dependent package - 2 dependent repositories - 212 stars on GitHub
Top 6.8% on proxy.golang.org
github.com/redpanda-data/connect/v4 v4.81.0 💰
Fancy stream processing made operationally mundane
179 versions - Latest release: 5 days ago - 8,474 stars on GitHub
Top 6.8% on proxy.golang.org
github.com/redpanda-data/connect v1.20.4 💰
Fancy stream processing made operationally mundane
295 versions - Latest release: almost 7 years ago - 8,474 stars on GitHub
Top 6.6% on proxy.golang.org
github.com/redpanda-data/connect/v3 v3.65.0 💰
Fancy stream processing made operationally mundane
99 versions - Latest release: almost 4 years ago - 8,474 stars on GitHub
Top 6.8% on proxy.golang.org
github.com/redpanda-data/connect/public/bundle/enterprise/v4 v4.78.1 💰
Fancy stream processing made operationally mundane
16 versions - Latest release: about 1 month ago - 8,474 stars on GitHub
Top 6.8% on proxy.golang.org
github.com/redpanda-data/connect/public/bundle/free/v4 v4.78.1 💰
Package free imports all free, open source plugin implementations that ship with Redpanda Connect...
16 versions - Latest release: about 1 month ago - 8,474 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/simon-xia/fuzzyquantile v0.0.0-20170810125847-0f2b52ae985e
Package fuzzyQuantile is a high performance quantile estimation(e.g. 90th, 95th, 99th) of streami...
1 version - Latest release: over 8 years ago - 3 stars on GitHub
Top 7.7% on proxy.golang.org
github.com/NeutrinoCorp/streams v0.2.6
:envelope: Streams is a toolkit crafted for data-in-motion ecosystems written in Go.
13 versions - Latest release: almost 4 years ago - 3 stars on GitHub
Top 6.7% on proxy.golang.org
github.com/ArroyoSystems/arroyo v0.15.0
Distributed stream processing engine in Rust
30 versions - Latest release: 3 months ago - 4,605 stars on GitHub
Top 7.7% on proxy.golang.org
github.com/neutrinocorp/streams/driver/amazon v0.0.0-20220504013750-b84f664f0f58
:envelope: Streams is a toolkit crafted for data-in-motion ecosystems written in Go.
1 version - Latest release: almost 4 years ago - 3 stars on GitHub
Top 5.2% on proxy.golang.org
github.com/whitaker-io/machine/common v0.1.1 💰
Machine is a workflow/pipeline library for processing data
2 versions - Latest release: over 2 years ago - 1 dependent package - 1 dependent repositories - 163 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/bartke/tributary v0.0.0-20201007144917-519a79d9fe81
Package tributary provides tools to build simple, flow based event stream processors.
1 version - Latest release: over 5 years ago - 1 stars on GitHub
Top 2.1% on proxy.golang.org
github.com/redpanda-data/redpanda/src/go/transform-sdk v0.0.0-20231111152103-701900dc1a99
Package redpanda is the SDK for Redpanda's inline Data Transforms, based on WebAssembly. This li...
309 versions - Latest release: over 2 years ago - 4 dependent packages - 2 dependent repositories - 11,181 stars on GitHub
Top 4.5% on proxy.golang.org
github.com/rmoff/ksqldb-go v0.0.0-20211103102223-35d4fd2fc474
A Golang client for ksqlDB
1 version - Latest release: over 4 years ago - 2 dependent packages - 5 dependent repositories - 66 stars on GitHub
Top 5.7% on proxy.golang.org
github.com/systemaccounting/mxfactorial v0.0.0-20231026194915-fc7a27765bed 💰
a payment application intended for deployment by the united states treasury that replaces banking...
27 versions - Latest release: over 2 years ago - 53 stars on GitHub
Top 9.8% on proxy.golang.org
github.com/constellation-rs/amadeus v0.4.3
Harmonious distributed data analysis in Rust.
24 versions - Latest release: almost 5 years ago - 481 stars on GitHub
Top 7.6% on proxy.golang.org
github.com/apache/streampipes/streampipes-client-go
Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to con...
Latest release: about 2 months ago - 695 stars on GitHub
Top 4.6% on proxy.golang.org
github.com/reugn/go-streams/nats v0.0.0-20231216092528-70c164944912
Package nats provides NATS streaming connectors.
7 versions - Latest release: about 2 years ago - 1 dependent repositories - 1,367 stars on GitHub
Top 5.8% on proxy.golang.org
github.com/itsubaki/gostream v0.0.2
Stream processing library for Go
2 versions - Latest release: 4 months ago - 1 dependent package - 1 dependent repositories - 56 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/zensey/go-data-routing v0.1.2
Pipelined data routing/trasnformation engine
3 versions - Latest release: over 5 years ago - 8 stars on GitHub
Top 3.4% on proxy.golang.org
github.com/redpanda-data/redpanda/src/go/k8s v0.0.0-20231110165536-326a03d562a2
Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKee...
1,419 versions - Latest release: over 2 years ago - 1 dependent repositories - 11,181 stars on GitHub
Top 5.4% on proxy.golang.org
github.com/redpanda-data/redpanda/bazel/pbgen
Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKee...
Latest release: about 2 months ago - 11,181 stars on GitHub
Top 6.7% on proxy.golang.org
github.com/nerevu/riko v0.66.0
A Python stream processing engine modeled after Yahoo! Pipes
103 versions - Latest release: over 5 years ago - 1,599 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/gazette/core v0.102.0
Gazette is a distributed byte-stream transaction engine. It models a concept of "journals": infin...
18 versions - Latest release: 6 days ago - 776 stars on GitHub
Top 5.2% on proxy.golang.org
github.com/jgraettinger/gazette
Build platforms that flexibly mix SQL, batch, and stream processing paradigms
Latest release: 3 months ago - 1 dependent repositories - 776 stars on GitHub
Top 6.0% on proxy.golang.org
github.com/FcoManueel/imtdigest v0.0.0-20200307234455-1f3825006e6f
IMT Digest is an utility to download arbitrary-sized files from an internet source, apply a hash ...
1 version - Latest release: almost 6 years ago - 1 stars on GitHub
Top 7.4% on proxy.golang.org
github.com/usedatabrew/blink v1.19.9
OpenSource data platform to build event-driven systems. It's like Deebezium for golang :)
77 versions - Latest release: over 1 year ago - 5 stars on GitHub
Top 9.3% on proxy.golang.org
github.com/whitaker-io/machine/edge/http v0.1.1 💰
Machine is a workflow/pipeline library for processing data
2 versions - Latest release: over 2 years ago - 163 stars on GitHub