An open-source engine that turns continuous content streams into search and monitoring. Durable ingestion, hybrid search, alerts, and plugins for formats, models and business rules.
Repository Index
47,133 repositories indexed
1–18 of 18 · Most stars
Streaming replication for SQLite.
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.
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
A lightweight stream processing library for Go
Lightweight data stream processing engine for IoT edge
Build platforms that flexibly mix SQL, batch, and stream processing paradigms
- golang
- event-sourcing
- stream-processing
- brokers
Streaming Postgres logical replication changes atleast-once over websockets
- postgresql
- logical-replication
- write-ahead-log
- websockets
A Go Mongo library based on the official MongoDB driver, featuring streamlined document operations, generic binding of structs to collections, built-in BSON doc builder, automated field updates, struct validation, hooks, and plugin-based programming.
- go
- mongo
- mongodb
- golang
Cloud-native continuous backup for PostgreSQL - WAL/base-backup streaming, compression, encryption, retention, and monitoring in a single binary.
redisqueue provides a producer and consumer of a queue that uses Redis streams
- go
- golang
- redis
- consumer
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
Go client to reliable queues based on Redis Cluster Streams
- go
- redis
- streams
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.
GunDB middleware for Fiber web framework. This middleware enables easy integration of GunDB, a decentralized database.
- decentralized-database
- go-fiber
- gundb
- middleware