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

proxy.golang.org "stream-processing" keyword

Top 6.7% on proxy.golang.org
github.com/bytewax/bytewax v0.21.1
Python Stream Processing
35 versions - Latest release: over 1 year ago - 1,813 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: almost 7 years ago - 7,961 stars on GitHub
Top 6.7% on proxy.golang.org
github.com/thibauts/styx v0.1.4
Simple, high-performance event streaming broker
5 versions - Latest release: almost 5 years ago - 50 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
github.com/chinalhr/go-stream v0.0.0-20230309031807-c606a614b2ce
Use Go to implement Java Stream API
2 versions - Latest release: about 3 years ago - 1 dependent package - 1 dependent repositories - 2 stars on GitHub
Top 6.7% on proxy.golang.org
github.com/infinyon/fluvio v0.18.1
🦀 event stream processing for developers to collect and transform data in motion to power respons...
181 versions - Latest release: 9 months ago - 5,065 stars on GitHub
Top 1.7% on proxy.golang.org
github.com/yomorun/yomo v1.21.4 💰
🦖 Serverless AI Agent Framework with Geo-distributed Edge AI Infra.
141 versions - Latest release: 5 days ago - 13 dependent packages - 20 dependent repositories - 1,847 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: 7 months ago - 429 dependent packages - 271 dependent repositories - 8,860 stars on GitHub
Top 5.8% on proxy.golang.org
github.com/siddhi-io/siddhi v5.1.31+incompatible
Stream Processing and Complex Event Processing Engine
415 versions - Latest release: about 1 year ago - 1,483 stars on GitHub
Top 6.7% on proxy.golang.org
github.com/pathwaycom/pathway v0.29.1
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
85 versions - Latest release: 29 days ago - 48,902 stars on GitHub
Top 7.8% on proxy.golang.org
github.com/kumkeehyun/gstream v0.1.0
Kafka Streams DSL liked, Stream Processing Library abstracting pipelines pattern using generic.
1 version - Latest release: about 3 years ago - 11 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: about 1 month ago - 4 dependent packages - 25 dependent repositories - 11,181 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/Jeffail/benthos/v4 v4.83.0 💰
Fancy stream processing made operationally mundane
184 versions - Latest release: 4 days ago - 6,899 stars on GitHub
Top 4.6% on proxy.golang.org
github.com/reugn/go-streams/pulsar v0.1.2
Package pulsar implements the Apache Pulsar connector.
3 versions - Latest release: about 5 years ago - 1 dependent repositories - 1,356 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...
177 versions - Latest release: about 1 year ago - 2,700 stars on GitHub
Top 6.0% on proxy.golang.org
github.com/PeerDB-io/peerdb/flow v0.0.0-20260316220213-cb7746a97ac1
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues...
20 versions - Latest release: 1 day ago - 2,728 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...
177 versions - Latest release: about 1 year ago - 2,728 stars on GitHub
Top 6.5% on proxy.golang.org
github.com/peerdb-io/peerdb/flow-api-client v0.5.3
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues...
27 versions - Latest release: 19 days ago - 2,728 stars on GitHub
Top 6.5% on proxy.golang.org
github.com/PeerDB-io/peerdb/flow-api-client v0.5.3
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues...
27 versions - Latest release: 19 days ago - 2,700 stars on GitHub
Top 5.5% on proxy.golang.org
github.com/PeerDB-io/peerdb/e2e_cleanup v0.0.0-20260316220213-cb7746a97ac1
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues...
10 versions - Latest release: 1 day 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,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 5.7% on proxy.golang.org
github.com/peerdb-io/peerdb/flow removed
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues...
Latest release: about 22 hours ago - 2,666 stars on GitHub
Top 1.4% on proxy.golang.org
github.com/benthosdev/benthos/v4 v4.83.0 💰
Fancy stream processing made operationally mundane
184 versions - Latest release: 4 days ago - 36 dependent packages - 9 dependent repositories - 5,853 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: about 4 years ago - 13 dependent packages - 9 dependent repositories - 5,851 stars on GitHub
Top 4.6% on proxy.golang.org
github.com/reugn/go-streams/aerospike v0.1.2
Package aerospike implements the Aerospike database 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/patrobinson/go-fish v0.0.0-20210310001137-5849f3079881
A Stream Processor written in Golang that support pluggable tasks
1 version - Latest release: about 5 years ago - 9 stars on GitHub
Top 3.6% on proxy.golang.org
github.com/THreeDotsLabs/watermill v1.5.1
Building event-driven applications the easy way in Go.
53 versions - Latest release: 7 months ago - 8,860 stars on GitHub
Top 5.6% on proxy.golang.org
github.com/redpanda-data/redpanda/src/transform-sdk/go v0.0.0-20231201061805-80dc735b5076
Package redpanda is the SDK for Redpanda's inline Data Transforms, based on WebAssembly. This li...
58 versions - Latest release: over 2 years ago - 11,181 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: 4 months ago - 4,605 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 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.7% on proxy.golang.org
github.com/quixio/quix-streams v3.23.4+incompatible
Python Streaming DataFrames for Kafka
64 versions - Latest release: 15 days ago - 1,474 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: 2 days ago - 11,181 stars on GitHub
Top 4.5% on proxy.golang.org
github.com/ThreeDotsLabs/watermill/docs/content/docs/message v0.2.1
Building event-driven applications the easy way in Go.
2 versions - Latest release: over 3 years ago - 9,105 stars on GitHub
github.com/fremantle-industries/tabletop v0.0.0-20230206013659-e084e47bf577 💰
A curated selection of tools, libraries and services that help tame your dataflow to productively...
17 versions - Latest release: about 3 years ago - 1 dependent package - 1 dependent repositories - 3 stars on GitHub
Top 5.7% on proxy.golang.org
github.com/whitaker-io/machine/cmd v0.0.0-20210206193628-f9591f4655a2 💰
Copyright © 2020 Jonathan Whitaker <jonathan@whitaker.io>
1 version - Latest release: about 5 years ago - 163 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/Supernomad/protond v0.0.0-20170306070718-38f40eff4052
Package main contains the main entrypoint for the protond application.
1 version - Latest release: about 9 years ago - 1 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: 4 months ago - 6 stars on GitHub
Top 5.6% on proxy.golang.org
github.com/findcoo/s4
Simple Storage Service Stream
Latest release: 2 months ago - 0 stars on GitHub
Top 5.8% on proxy.golang.org
github.com/airtai/faststream v0.5.39
FastStream is a powerful and easy-to-use Python framework for building asynchronous services inte...
1 version - Latest release: 11 months ago - 3,685 stars on GitHub
Top 6.1% on proxy.golang.org
github.com/benthosdev/connect/public/bundle/free/v4 v4.83.0 💰
Fancy stream processing made operationally mundane
18 versions - Latest release: 4 days ago - 8,165 stars on GitHub
Top 5.2% on proxy.golang.org
github.com/vectorengine/vectorsql v0.0.0-20211016084406-145960c10706
VectorSQL is a free analytics DBMS for IoT & Big Data, compatible with ClickHouse.
1 version - Latest release: over 4 years ago - 255 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/maxhalford/tuna v0.0.0-20190124141118-f150c5cccea4
:fish: A streaming ETL for fish
1 version - Latest release: about 7 years ago - 13 stars on GitHub
Top 6.7% on proxy.golang.org
github.com/deep5050/radio-active v3.0.0+incompatible 💰
Play any radios around the globe right from the terminal :zap:
9 versions - Latest release: about 2 months ago - 460 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: 7 months ago - 9,105 stars on GitHub
Top 7.1% on proxy.golang.org
github.com/MaxHalford/tuna v0.0.0-20190124141118-f150c5cccea4 💰
:fish: A streaming ETL for fish
1 version - Latest release: about 7 years ago - 13 stars on GitHub
Top 7.8% on proxy.golang.org
github.com/vectorhacker/goro v0.0.0-20190214062036-055fb2d745ac
Package goro is pure Go client library for dealing with Event Store (versions 3.2.0 and later). I...
1 version - Latest release: about 7 years ago - 1 dependent package - 1 dependent repositories - 11 stars on GitHub
Top 7.6% on proxy.golang.org
github.com/reugn/go-streams/websocket
Package websocket implements the WebSocket connector.
Latest release: 3 months ago - 1,761 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 8.2% on proxy.golang.org
github.com/hstreamdb/hstream v0.20.3
HStreamDB is an open-source, cloud-native streaming database for IoT and beyond. Modernize your d...
54 versions - Latest release: over 1 year ago - 727 stars on GitHub
Top 6.7% on proxy.golang.org
github.com/risingwavelabs/risingwave v2.8.0+incompatible
Streaming data platform for real-time stream processing, low-latency serving, and Iceberg table m...
120 versions - Latest release: 16 days ago - 8,464 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.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: about 2 years ago - 69 stars on GitHub
Top 9.9% on proxy.golang.org
github.com/akhenakh/geo-benthos v0.0.0-20240227051811-600248b680e8
Benthos plugins to transform geographic coordinates from a stream.
2 versions - Latest release: about 2 years ago - 3 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 3.5% on proxy.golang.org
github.com/numaproj/numaflow v1.7.4
Kubernetes-native platform to run massively parallel data/streaming jobs
82 versions - Latest release: 4 days ago - 1 dependent package - 2 dependent repositories - 2,346 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: 10 months ago - 1 dependent repositories - 798 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 4.5% on proxy.golang.org
github.com/ThreeDotsLabs/watermill/dev/wait-for v0.0.0-20221103101124-9c543c21c394
Building event-driven applications the easy way in Go.
1 version - Latest release: over 3 years ago - 8,860 stars on GitHub
Top 4.1% on proxy.golang.org
github.com/materializeinc/materialize v26.15.0+incompatible
Real-time Data Integration and Transformation: use SQL to transform, deliver, and act on fast-cha...
720 versions - Latest release: 6 days ago - 6,153 stars on GitHub
github.com/getkalido/fungi v1.1.0
Functional stream processing primitives for Go
16 versions - Latest release: 10 months ago - 1 dependent repositories - 0 stars on GitHub
Top 6.7% on proxy.golang.org
github.com/RisingWaveLabs/risingwave v2.8.0+incompatible
Streaming data platform for real-time stream processing, low-latency serving, and Iceberg table m...
119 versions - Latest release: 16 days ago - 8,464 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/supernomad/protond v0.0.0-20170306070718-38f40eff4052
Package main contains the main entrypoint for the protond application.
1 version - Latest release: about 9 years ago - 1 stars on GitHub
Top 6.7% on proxy.golang.org
github.com/synacker/daggy v2.2.4+incompatible
Daggy - Data Aggregation Utility and C/C++ developer library for data streams catching
7 versions - Latest release: 5 months ago - 150 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/bytewatch/dolphinbeat v0.0.0-20190123140659-64b8ef3307e7
A server that pulls and parses MySQL binlog, pushs change data into different sinks like Kafka.
1 version - Latest release: about 7 years ago - 169 stars on GitHub
Top 5.6% on proxy.golang.org
github.com/redpanda-data/redpanda/src/transform-sdk/go/transform v1.1.0
Package transform is the SDK for Redpanda's inline Data Transforms, based on WebAssembly. This l...
111 versions - Latest release: over 1 year ago - 11,181 stars on GitHub
Top 6.3% on proxy.golang.org
github.com/carverauto/eventrunner
high-speed opensource event processing engine
Latest release: 6 days ago - 3 stars on GitHub
Top 5.9% on proxy.golang.org
github.com/memgraph/memgraph v3.8.1+incompatible
Open-source graph database, tuned for dynamic analytics environments. Easy to adopt, scale and own.
137 versions - Latest release: 29 days ago - 3,696 stars on GitHub
Top 6.2% on proxy.golang.org
github.com/dianacohencs/measure-traces
Repo for measuring (Internet) traces. Evaluate micro-batching in data stream processing and the i...
Latest release: 4 months ago - 0 stars on GitHub
Top 4.6% on proxy.golang.org
github.com/reugn/go-streams/ws v0.1.2
Package ws implements the WebSocket 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/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 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 4.8% on proxy.golang.org
github.com/reugn/go-streams/examples
A lightweight stream processing library for Go
Latest release: about 1 month ago - 1,367 stars on GitHub
Top 9.5% on proxy.golang.org
github.com/gfleury/gstreamtop
Real time analytical SQL Query on text streams
Latest release: 2 months ago - 3 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: about 1 year 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: 4 months ago - 6 stars on GitHub
Top 2.8% on proxy.golang.org
go.gazette.dev/core v0.102.0
Build platforms that flexibly mix SQL, batch, and stream processing paradigms
18 versions - Latest release: 28 days ago - 5 dependent packages - 4 dependent repositories - 736 stars on GitHub
Top 8.2% on proxy.golang.org
github.com/yaricom/gostream v1.0.0
Package gostream implements data stream based on Redis stream
1 version - Latest release: over 5 years ago - 0 stars on GitHub
Top 5.7% on proxy.golang.org
github.com/EventStore/EventStoreDB-Client-Java v1.1.2
KurrentDB Java Client
8 versions - Latest release: 20 days ago - 65 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 3.7% on proxy.golang.org
github.com/hazelcast/hazelcast v5.6.0+incompatible
Hazelcast is a unified real-time data platform combining stream processing with a fast data store...
238 versions - Latest release: 5 months ago - 1 dependent repositories - 6,412 stars on GitHub
Top 3.4% on proxy.golang.org
github.com/project-flogo/stream v0.3.0
Elegant stream processing pipeline written entirely in Golang
7 versions - Latest release: about 6 years ago - 13 dependent packages - 6 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: 7 months ago - 9,105 stars on GitHub
Top 9.0% on proxy.golang.org
github.com/runreveal/kawa v0.2.3
A blazingly fast event stream processing library powering the reveald event processing daemon.
16 versions - Latest release: 4 months ago - 129 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 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: 7 months ago - 8,860 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: 3 months ago - 0 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 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: almost 7 years ago - 1 dependent repositories - 66 stars on GitHub
Top 7.8% on proxy.golang.org
github.com/KumKeeHyun/gstream v0.1.0
Package gstream is stream processing library abstracting pipelines pattern using generic. Exampl...
1 version - Latest release: about 3 years ago - 11 stars on GitHub
Top 8.0% on proxy.golang.org
github.com/heyoka/faxe v1.3.18
1 version - Latest release: over 1 year ago - 20 stars on GitHub
Top 9.7% on proxy.golang.org
github.com/redpanda-data/redpanda/src/go/cluster-to-redpanda-migration v0.0.0-20230920233823-0b32bc8b6e41
Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKee...
3 versions - Latest release: over 2 years ago - 11,181 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: 7 months ago - 9,105 stars on GitHub
Top 6.7% on proxy.golang.org
github.com/robinhood/faust v1.10.3
Python Stream Processing
135 versions - Latest release: about 6 years ago - 6,823 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 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 9.0% on proxy.golang.org
github.com/nikolaydubina/go-bench-stream 💰
🌊 Go Benchmarks for Stream Processing
Latest release: 3 months ago - 2 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: almost 8 years ago - 4 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: 3 months ago - 1 dependent package - 1 dependent repositories - 222 stars on GitHub