Building event-driven applications the easy way in Go.
- watermill
- event-driven
- event-sourcing
- sagas
Repository Index
87,075 visible repositories in the index
1–24 of 33 · Most stars
Fancy stream processing made operationally mundane
- message-queue
- stream-processing
- streaming-data
- message-bus
The live data layer for apps and AI agents. Create up-to-the-second views into your business, just using SQL
🦀 event stream processing for developers to collect and transform data in motion to power responsive data intensive applications.
- cloud-native
- streaming
- rust
- real-time
Reactive Extensions for the Go language.
- reactivex
- golang
- observable
- go
Canonical actor model implementation for .NET with local + distributed actors in C# and F#.
- akka
- actor-model
- dotnet
- concurrency
Distributed stream processing engine in Rust
- data
- dev-tools
- infrastructure
- kafka
A network event stream processing system, in Clojure.
- riemann
- events
- clojure
- monitoring
StreamAlert is a serverless, realtime data analysis framework which empowers you to ingest, analyze, and alert on data from any environment, using datasources and alerting logic you define.
- security
- kinesis
- serverless
- terraform
Concurrent and multi-stage data ingestion and data processing with Elixir
- elixir
- genstage
- data-ingestion
- data-processing
Project Flogo is an open source ecosystem of opinionated event-driven capabilities to simplify building efficient & modern serverless functions, microservices & edge apps.
- flogo
- iot
- integration
- golang
Open source framework for processing, monitoring, and alerting on time series data
- kapacitor
- monitoring
- time-series
YTsaurus is a scalable and fault-tolerant open-source big data platform.
- big-data
- clickhouse
- distributed-database
- lakehouse
Ruby and Rails efficient Kafka processing framework
- karafka-framework
- kafka
- kafka-client
- kafka-clients
Probabilistic data structures for processing continuous, unbounded streams.
- bloom-filter
- go
- stable-bloom-filters
- cuckoo-filter
A Python stream processing engine modeled after Yahoo! Pipes
- stream-processing
- etl
- parallelism
- rss
Python Streaming DataFrames for Kafka
A compatibility layer for event-driven abstractions
- stream-processing
- future
- clojure
- async
🌊 Continuously synchronize the systems where your data lives, to the systems where you _want_ it to live, by managing your data flows with Estuary. 🌊
- change-data-capture
- data
- data-collection
- data-engineering
Esper Complex Event Processing, Streaming SQL and Event Series Analysis
- cep
- complex-event-processing
- open-source
- compiler
A functional effect and streaming system for Clojure/Script
- clojure
- clojurescript
- reactive-streams
Build platforms that flexibly mix SQL, batch, and stream processing paradigms
- golang
- event-sourcing
- stream-processing
- brokers
Tenzir is the data pipeline engine for security teams.
- incident-response
- threathunting
- siem
- soc
HStreamDB is an open-source, cloud-native streaming database for IoT and beyond. Modernize your data stack for real-time applications.