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

proxy.golang.org "stream-processing" keyword

View the packages on the proxy.golang.org package registry that are tagged with the "stream-processing" keyword.

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: 5 months ago - 429 dependent packages - 271 dependent repositories - 8,860 stars on GitHub
Top 5.7% on proxy.golang.org
github.com/whitaker-io/machine/v2 v2.2.1 💰
Package machine - Copyright © 2020 Jonathan Whitaker <github@whitaker.io>. Use of this source co...
11 versions - Latest release: over 2 years ago - 163 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 1.7% on proxy.golang.org
github.com/yomorun/yomo v1.21.1 💰
🦖 Serverless AI Agent Framework with Geo-distributed Edge AI Infra.
138 versions - Latest release: 5 days ago - 13 dependent packages - 20 dependent repositories - 1,847 stars on GitHub
Top 4.5% on proxy.golang.org
github.com/streamnative/function-mesh v0.26.1
The serverless framework purpose-built for event streaming applications.
161 versions - Latest release: about 2 months ago - 1 dependent package - 1 dependent repositories - 222 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/asavinov/bistro v0.8.0
A general-purpose data analysis engine radically changing the way batch and stream data is processed
8 versions - Latest release: over 7 years ago - 4 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 6.7% on proxy.golang.org
github.com/robinhood/faust v1.10.3
Python Stream Processing
135 versions - Latest release: almost 6 years ago - 6,823 stars on GitHub
Top 8.0% on proxy.golang.org
github.com/heyoka/faxe v1.3.18
1 version - Latest release: about 1 year ago - 20 stars on GitHub
Top 6.0% on proxy.golang.org
github.com/vertexclique/callysto v0.1.9 💰
Stream processing framework.
8 versions - Latest release: over 3 years ago - 88 stars on GitHub
Top 1.4% on proxy.golang.org
github.com/benthosdev/benthos/v4 v4.79.0 💰
Fancy stream processing made operationally mundane
176 versions - Latest release: 2 days ago - 36 dependent packages - 9 dependent repositories - 5,853 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/relloyd/halfpipe v0.2.4
Halfpipe is an ELT utility and microservice that streams data into Snowflake from S3, Oracle, SQL...
7 versions - Latest release: almost 4 years ago - 6 stars on GitHub
Top 5.8% on proxy.golang.org
github.com/kurrent-io/KurrentDB-Client-Go v1.1.1
KurrentDB Go Client
4 versions - Latest release: 2 months ago - 6 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/konimarti/flow v0.2.0
Create simple flows based on user-defined filters (data stream processing).
2 versions - Latest release: over 6 years ago - 18 stars on GitHub
Top 5.6% on proxy.golang.org
github.com/iferdel/sensor-data-streaming-pubsub v1.0.0
Hybrid IIoT system using PubSub as backbone by means of Go/RabbitMQ, PostgreSQL with TimeScaleDB ...
1 version - Latest release: 12 months ago - 6 stars on GitHub
Top 4.5% on proxy.golang.org
github.com/ThreedotsLabs/watermill v1.5.1
Building event-driven applications the easy way in Go.
53 versions - Latest release: 5 months ago - 9,105 stars on GitHub
Top 1.3% on proxy.golang.org
github.com/redpanda-data/redpanda/src/go/rpk v0.0.0-20240126012634-48f29ec9fa17
Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKee...
2,075 versions - Latest release: about 2 years ago - 4 dependent packages - 25 dependent repositories - 11,181 stars on GitHub
github.com/sgaunet/logwrap v0.2.0
Command execution wrapper that adds configurable prefixes to log output streams with real-time fo...
2 versions - Latest release: about 2 months ago - 0 stars on GitHub
Top 6.0% on proxy.golang.org
github.com/project-flogo/stream/activity/aggregate v0.2.0
Elegant stream processing pipeline written entirely in Golang
1 version - Latest release: over 6 years ago - 1 dependent repositories - 66 stars on GitHub
Top 4.5% on proxy.golang.org
github.com/ThreeDotsLabs/Watermill v1.5.1
Building event-driven applications the easy way in Go.
53 versions - Latest release: 5 months ago - 8,860 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/benthosdev/benthos-captain v0.1.0
A Kubernetes Operator to orchestrate Benthos pipelines
2 versions - Latest release: about 2 years ago - 44 stars on GitHub
Top 6.7% on proxy.golang.org
github.com/lsds/LightSaber v0.0.2
Multi-core Window-Based Stream Processing Engine
2 versions - Latest release: over 4 years ago - 67 stars on GitHub
Top 6.8% on proxy.golang.org
github.com/redpanda-data/connect/v4 v4.78.0 💰
Fancy stream processing made operationally mundane
173 versions - Latest release: 16 days 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: 13 days 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: 13 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: over 6 years ago - 8,474 stars on GitHub
Top 5.7% on proxy.golang.org
github.com/eventstore/eventstoredb-client-java v1.1.0
KurrentDB Java Client
6 versions - Latest release: 3 months ago - 65 stars on GitHub
Top 6.3% on proxy.golang.org
github.com/naughtygopher/nibbler v0.2.2
Package nibbler provides a simple interface for micro-batch processing Each micro batch can star...
3 versions - Latest release: 3 months ago - 8 stars on GitHub
Top 9.5% on proxy.golang.org
github.com/whitaker-io/machine/telemetry v0.1.8 💰
Package telemetry is a package that provides a slog.Handler that supports telemetry messages.
9 versions - Latest release: about 2 years ago - 163 stars on GitHub
Top 6.7% on proxy.golang.org
github.com/maki-nage/makinage v0.8.0
Stream Processing Made Easy
11 versions - Latest release: over 4 years ago - 38 stars on GitHub
Top 4.5% on proxy.golang.org
github.com/Threedotslabs/watermill v1.5.1
Building event-driven applications the easy way in Go.
53 versions - Latest release: 5 months ago - 9,105 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/nmaquet/kasper v0.0.0-20170723232437-1cd831cad03d
Kasper is a lightweight library for processing Kafka topics. It is heavily inspired by Apache Sam...
1 version - Latest release: over 8 years ago - 439 stars on GitHub
Top 6.8% on proxy.golang.org
github.com/benthosdev/connect/v4 v4.78.0 💰
Fancy stream processing made operationally mundane
173 versions - Latest release: 16 days ago - 7,744 stars on GitHub
Top 6.3% on proxy.golang.org
github.com/wso2/siddhi v5.1.31+incompatible
Stream Processing and Complex Event Processing Engine
414 versions - Latest release: 11 months ago - 1,514 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/flogo-oss/stream v0.3.0
Elegant stream processing pipeline written entirely in Golang
7 versions - Latest release: about 6 years ago - 60 stars on GitHub
Top 6.5% on proxy.golang.org
github.com/peerdb-io/peerdb v2.0.1+incompatible
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues...
171 versions - Latest release: 12 months ago - 2,728 stars on GitHub
Top 5.7% on proxy.golang.org
github.com/peerdb-io/peerdb/flow
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues...
Latest release: 7 days ago - 2,666 stars on GitHub
Top 6.5% on proxy.golang.org
github.com/peerdb-io/peerdb/flow-api-client v0.5.2
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues...
26 versions - Latest release: about 2 months ago - 2,728 stars on GitHub
Top 6.5% on proxy.golang.org
github.com/PeerDB-io/peerdb/flow-api-client v0.5.2
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues...
26 versions - Latest release: about 2 months ago - 2,700 stars on GitHub
Top 6.5% on proxy.golang.org
github.com/peerdb-io/peerdb/flow/flow-api-client v0.1.1
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues...
2 versions - Latest release: over 1 year ago - 2,728 stars on GitHub
Top 6.5% on proxy.golang.org
github.com/PeerDB-io/peerdb/flow/flow-api-client v0.1.1
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues...
2 versions - Latest release: over 1 year ago - 2,666 stars on GitHub
Top 6.0% on proxy.golang.org
github.com/PeerDB-io/peerdb/flow
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues...
Latest release: 7 days ago - 2,728 stars on GitHub
Top 5.5% on proxy.golang.org
github.com/PeerDB-io/peerdb/e2e_cleanup
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues...
Latest release: 7 days ago - 2,728 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/hazelcast/hazelcast-jet v4.5.4+incompatible
Distributed Stream and Batch Processing
15 versions - Latest release: about 3 years ago - 1,046 stars on GitHub
Top 9.6% on proxy.golang.org
github.com/ibmstreams/streamsx.topology v2.2.0+incompatible
Develop streaming applications for IBM Streams in Python, Java & Scala.
70 versions - Latest release: over 3 years ago - 28 stars on GitHub
Top 9.3% on proxy.golang.org
github.com/whitaker-io/machine/edge/pubsub v0.1.2 💰
Machine is a workflow/pipeline library for processing data
3 versions - Latest release: about 2 years ago - 163 stars on GitHub
Top 9.6% on proxy.golang.org
github.com/smooks/smooks v2.2.1+incompatible
Extensible data integration Java framework for building XML and non-XML fragment-based applications
18 versions - Latest release: 12 months ago - 377 stars on GitHub
Top 7.2% on proxy.golang.org
github.com/affo/ssp
Simple Stream Processor (Golang)
Latest release: 9 days ago - 2 stars on GitHub
Top 6.7% on proxy.golang.org
github.com/halaxa/json-machine v0.2.1 💰
Efficient, easy-to-use, and fast PHP JSON stream parser
3 versions - Latest release: about 7 years ago - 1,021 stars on GitHub
github.com/kenju/go-pipeline v0.2.6
concurrent stream-processing library in Go
13 versions - Latest release: almost 7 years ago - 1 dependent repositories - 3 stars on GitHub
Top 6.9% on proxy.golang.org
github.com/streamnative/function-mesh/api
The serverless framework purpose-built for event streaming applications.
Latest release: 9 days ago - 222 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: 10 days ago - 27 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: over 6 years ago - 66 stars on GitHub
Top 3.5% on proxy.golang.org
github.com/numaproj/numaflow v1.7.0
Kubernetes-native platform to run massively parallel data/streaming jobs
78 versions - Latest release: 3 months ago - 1 dependent package - 2 dependent repositories - 2,346 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 6.5% on proxy.golang.org
github.com/PeerDB-io/peerdb v2.0.1+incompatible
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues...
171 versions - Latest release: 12 months ago - 2,700 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.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 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 8.2% on proxy.golang.org
github.com/gazette/core v0.101.0
Gazette is a distributed byte-stream transaction engine. It models a concept of "journals": infin...
17 versions - Latest release: 4 months ago - 776 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: 4 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 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 6.3% on proxy.golang.org
github.com/google-ai-edge/mediapipe v0.10.26
Cross-platform, customizable ML solutions for live and streaming media.
54 versions - Latest release: 7 months ago - 31,555 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: almost 2 years ago - 2 dependent packages - 3 dependent repositories - 63 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 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: almost 8 years ago - 11 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 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 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/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
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 5.9% on proxy.golang.org
github.com/logrange/logrange v0.1.48
High performance data aggregating storage
12 versions - Latest release: almost 5 years ago - 1 dependent repositories - 192 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: about 2 years ago - 1 dependent package - 1 dependent repositories - 163 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 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 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 9.5% on proxy.golang.org
github.com/qntfy/frinesis v0.1.1
Frizzle for AWS Kinesis
3 versions - Latest release: almost 7 years ago - 1 dependent package - 1 dependent repositories - 2 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.5% on proxy.golang.org
github.com/project-flogo/stream/trigger/streamtester 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 7.6% on proxy.golang.org
github.com/affo/ssp/lib v0.0.0
Simple Stream Processor (Golang)
1 version - Latest release: over 6 years ago - 2 stars on GitHub
Top 7.6% on proxy.golang.org
github.com/affo/ssp/ssp v0.0.0
Simple Stream Processor (Golang)
1 version - Latest release: over 6 years ago - 2 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: almost 2 years ago - 57 stars on GitHub
Top 5.6% on proxy.golang.org
github.com/findcoo/s4
Simple Storage Service Stream
Latest release: 18 days ago - 0 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 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 6.7% on proxy.golang.org
github.com/quixio/quix-streams v3.23.1+incompatible
Python Streaming DataFrames for Kafka
61 versions - Latest release: 4 months ago - 1,474 stars on GitHub
Top 9.6% on proxy.golang.org
github.com/vaerohq/vaero v0.0.0-20230326234109-997ee29fc82d
Complete log pipeline solution in Python. Runs fast in Go.
1 version - Latest release: almost 3 years ago - 62 stars on GitHub
Top 8.4% on proxy.golang.org
github.com/mvbrock/clusterizer
A scalable streaming cluster analysis command line tool
Latest release: 19 days ago - 0 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 9.6% on proxy.golang.org
github.com/IBMStreams/streamsx.topology v2.2.0+incompatible
Develop streaming applications for IBM Streams in Python, Java & Scala.
70 versions - Latest release: over 3 years ago - 28 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: about 2 years ago - 163 stars on GitHub
Top 6.6% on proxy.golang.org
github.com/benthosdev/connect v1.20.4 💰
Fancy stream processing made operationally mundane
295 versions - Latest release: over 6 years ago - 7,961 stars on GitHub
Top 7.0% on proxy.golang.org
github.com/spy16/fusion/reactor v0.0.0-20210121093714-f50f2731eed8
💥 Fusion is a tiny stream processing library written in Go.
1 version - Latest release: about 5 years ago - 17 stars on GitHub
Top 4.5% on proxy.golang.org
github.com/ThreeDotsLabs/watermill/dev/update-examples-deps v0.0.0-20230716085306-43d9a13d1ed0
Building event-driven applications the easy way in Go.
7 versions - Latest release: over 2 years ago - 9,105 stars on GitHub
Top 6.5% on proxy.golang.org
github.com/zefhub/zef v0.16.0
Toolkit for graph-relational data across space and time
1 version - Latest release: over 3 years ago - 117 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
Top 4.9% on proxy.golang.org
github.com/vladimirvivien/automi v0.2.1
A stream processing API for Go (now with generic type support)
3 versions - Latest release: 8 months ago - 1 dependent repositories - 798 stars on GitHub
Top 6.7% on proxy.golang.org
github.com/scramjetorg/transform-hub v1.0.1 💰
Scramjet Transform Hub (STH) is a runtime supervisor that can run data processing programs called...
91 versions - Latest release: almost 2 years ago - 69 stars on GitHub