Watermill

Working efficiently with message streams. Building event driven applications, enabling event sourcing, RPC over messages, sagas. Can use conventional pub/sub implementations like Kafka or RabbitMQ, but also HTTP or MySQL binlog.

cqrsevent-drivenevent-sourcingeventsgogolangkafkanatsrabbitmqreactivesagasstream-processingwatermill
View on GitHub Homepage
9,600
Stars
495
Forks
102
Issues
9,600
Watchers

Similar Packages

Asynq

A simple, reliable, and efficient distributed task queue for Go built on top of Redis.

13,037

sarama

Go library for Apache Kafka.

12,446

Centrifugo

Real-time messaging (Websockets or SockJS) server in Go.

10,084

gorush

Push notification server using [APNs2](https://github.com/sideshow/apns2) and google [GCM](https://github.com/google/go-gcm).

8,701

machinery

Asynchronous task queue/job queue based on distributed message passing.

7,948