Scalable real-time messaging server in a language-agnostic way. Self-hosted alternative to Pubnub, Pusher, Ably, socket.io, Phoenix.PubSub, SignalR. Set up once and forever.
Repository Index
47,133 repositories indexed
1–24 of 25 · Most stars
Building event-driven applications the easy way in Go.
- watermill
- event-driven
- event-sourcing
- sagas
Fancy stream processing made operationally mundane
- message-queue
- stream-processing
- streaming-data
- message-bus
Privacy and Security focused Segment-alternative, in Golang and React
- privacy
- warehouse-management
- data-warehouse
- customer-data
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage
- etl
- sql
- bigquery
- cloud-native
KubeBlocks is a Kubernetes Operator designed to manage a variety of databases and streaming systems, including MySQL, PostgreSQL, MongoDB, Redis, RabbitMQ, RocketMQ, and more, within Kubernetes environments.
- mysql-operator
- mongodb-operator
- postgresql-operator
- rabbitmq-operator
Kafka-style message streaming in Go. Built on NATS. Single binary, no JVM, no ZooKeeper.
A lightweight stream processing library for Go
Lightweight data stream processing engine for IoT edge
omniparser: a native Golang ETL streaming parser and transform library for CSV, JSON, XML, EDI, text, etc.
- transform
- etl
- xml
- json
Build platforms that flexibly mix SQL, batch, and stream processing paradigms
- golang
- event-sourcing
- stream-processing
- brokers
🏎️ Streams & Reactive Programming paradigm for Go: declarative and composable API for event-driven applications
- event-driven
- generics
- go
- golang
Conduit streams data between data stores. Kafka Connect replacement. No JVM required.
- go
- data-integration
- etl
- data-pipeline
Monad, Functional Programming features for Golang
- golang
- functional-programming
- functional-reactive-programming
- reactive
Lightweight stream processing engine for IoT
A Go port of the Java Streams API. Type-safe and functional Go Streams processing
- golang
- go
- stream-processing
- generics
Machine is a workflow/pipeline library for processing data
- golang
- golang-library
- golang-package
- workflow
Build event-driven and event streaming applications with ease
- golang
- commander
- cqrs
- event-sourcing
Lightweight SQL-based stream processing engine for IoT edge.
Stream database events from PostgreSQL to Kafka
- postgresql
- events
- stream
- kafka
☝️ go-graphql subscription over Kafka/Redis/NSQ example
A library for scheduling when to dispatch a message to a channel
A light-weight package for in-app micro batch processing
- batch
- batch-processing
- event-processing
- go
A production-grade messaging abstraction for Go. It provides a unified API to decouple business logic from various brokers including Kafka, RabbitMQ, RocketMQ, NATS, Redis, and AWS SQS. Featuring built-in OpenTelemetry integration and engineered for high reliability.