Building event-driven applications the easy way in Go.
- watermill
- event-driven
- event-sourcing
- sagas
Repository Index
47,133 repositories indexed
1–17 of 17 · Most stars
Fancy stream processing made operationally mundane
- message-queue
- stream-processing
- streaming-data
- message-bus
Machinery is an asynchronous task queue/job queue based on distributed message passing.
- go
- golang
- task
- task-scheduler
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
An AMQP 0-9-1 Go client maintained by the RabbitMQ team. Originally by @streadway: `streadway/amqp`
Test your code without writing mocks with ephemeral Docker containers 📦 Setup popular services with just a couple lines of code ⏱️ No bash, no yaml, only code 💻
- go
- golang
- testing
- integration-testing
This is the go boilerplate on the top of fiber web framework. With simple setup you can use many features out of the box
- go
- golang
- fiber-framework
- paypal
RabbitMQ wire tap and swiss army knife
- rabbitmq
- tap
- wiretap
- golang
:incoming_envelope: A fast Message/Event Hub using publish/subscribe pattern with support for topics like* rabbitMQ exchanges for Go applications
- topic
- pubsub
- go
- golang
Lightweight library that handles RabbitMQ auto-reconnect and publishing retry routine for you.
- rabbitmq
- amqp
- failover
- go
A tiny wrapper over amqp exchanges and queues 🚌 ✨
- rabbitmq
- eventbus
- microservices
- golang
Declare AMQP entities like queues, producers, and consumers in a declarative way. Can be used to work with RabbitMQ.
- amqp
- rabbitmq
- rabbit
- golang
Distributed batch data processing framework
Unlimited job queue for go, using a pool of concurrent workers processing the job queue entries
RabbitMQ Reconnection client
Abstraction layer for simple rabbitMQ connection, messaging and administration
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.