ThreeDotsLabs/watermill

Watermill is a Go library that provides a unified interface for building event-driven and real-time applications by abstracting various message brokers. It offers a comprehensive suite of components for message routing, CQRS, and transactional event handling, alongside middleware for reliability and observability. The system supports a wide range of pub/sub backends, including Kafka, RabbitMQ, AWS SNS/SQS, and SQL databases, with examples demonstrating their integration.

This period centered on the release of Watermill v1.0.0, which established a stable, production-ready API by removing legacy event store implementations and in-memory Pub/Sub components. The work significantly expanded the library's capabilities through new middleware, CQRS, and metrics components, while simultaneously broadening the ecosystem with extensive examples for Kafka, AMQP, NATS, and SQL-based messaging systems.

35 changes

This period focused on expanding the library's capabilities by introducing new components for message routing, delayed processing, and request/reply patterns. The team also significantly enriched the repository with diverse, validated examples covering various pub/sub backends and architectural patterns like CQRS and consumer groups.

16 changes

ThreeDotsLabs/watermill was measured the same way every project in this corpus was: the same rubric, at a pinned commit, with the result published in full. Point the surveyor at a repository you know and see whether you agree with it.