Fancy stream processing made operationally mundane
- message-queue
- stream-processing
- streaming-data
- message-bus
Repository Index
47,133 repositories indexed
1–8 of 8 · Most stars
Machinery is an asynchronous task queue/job queue based on distributed message passing.
- go
- golang
- task
- task-scheduler
An AMQP 0-9-1 Go client maintained by the RabbitMQ team. Originally by @streadway: `streadway/amqp`
RabbitMQ wire tap and swiss army knife
- rabbitmq
- tap
- wiretap
- 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
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.