Building event-driven applications the easy way in Go.

An example Event-Driven application in Go built with Watermill library.

An example Go project for running local development environment, with hot code reloading.

SQL (Postgres/MySQL) Pub/Sub for the Watermill project.

Kafka Pub/Sub for the Watermill project.

🦀 Online statistics in Rust

CQRS and event sourcing example in go

NATS Pub/Sub for the Watermill project.

No description available

Go template for the AsyncAPI Generator using Watermill module

AMQP Pub/Sub for the Watermill project.

Redis Pub/Sub for the Watermill project.

💧Bionode-Watermill: A (Not Yet Streaming) Workflow Engine

HTTP Pub/Sub for the Watermill project.

OpenTelemetry integration for Watermill

Benchmarking tools for Watermill.

Google Cloud Pub/Sub Pub/Sub for the Watermill project.

A Minecraft Mod which adds watermills, trousers, rotors, machines.

SQLite Pub/Sub for the Watermill project.

CockroachDB Pub/Sub for the Watermill project.

Amazon SQS/SNS Pub/Sub for the Watermill project.

A demonstration on building event-driven application, @ Golang Taipei Short Talk, Feb 2021.

The implementation of watermill.LogAdapter with zap

Kincir is a Rust message streaming library inspired by Watermill (Go), providing a unified interface for working with multiple message broker backends like Kafka and RabbitMQ. ## ✨ Key Features: - Unified messaging interface across different backends - Message routing with customizable handlers

protoc plugin to publish protobuf messages with Watermill

See https://github.com/ThreeDotsLabs/watermill-nats

An example that shows how GO, Kafka, Grafana, Prometheus can work together

Event-driven ticket booking system in Go using CQRS, Event Sourcing, and the Outbox Pattern with Watermill, PostgreSQL, and Redis.

IO Pub/Sub for the Watermill project.

An example of how a realtime feed would work with GO + Kafka + Watermill