watermill

ThreeDotsLabs/event-driven-example

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

ThreeDotsLabs/nats-example

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

ThreeDotsLabs/watermill-sql

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

ThreeDotsLabs/watermill-kafka

Kafka Pub/Sub for the Watermill project.

pperaltaisern/go-example-financing

CQRS and event sourcing example in go

roblaszczak/watermill-livecoding

ThreeDotsLabs/watermill-nats

NATS Pub/Sub for the Watermill project.

ThreeDotsLabs/watermill-amqp

AMQP Pub/Sub for the Watermill project.

asyncapi/go-watermill-template

Go template for the AsyncAPI Generator using Watermill module

ThreeDotsLabs/watermill-redisstream

Redis Pub/Sub for the Watermill project.

ThreeDotsLabs/watermill-http

HTTP Pub/Sub for the Watermill project.

voi-oss/watermill-opentelemetry

OpenTelemetry integration for Watermill

ThreeDotsLabs/watermill-benchmark

Benchmarking tools for Watermill.

ThreeDotsLabs/watermill-googlecloud

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

cockroachdb/watermill-crdb

CockroachDB Pub/Sub for the Watermill project.

minghsu0107/golang-taipei-watermill-example

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

ThreeDotsLabs/watermill-io

IO Pub/Sub for the Watermill project.

davidroman0O/watermill-comfymill

Watermill Sqlite3 Pub/Sub

ThreeDotsLabs/watermill-bolt

Bolt Pub/Sub for the Watermill project.

igmagollo/undine

An opinionated library that combines Ent and Watermill into a set of powerful utilities to transactionally handle events.

dentech-floss/watermill-googlecloud-http

Provides support for Watermill http push subscriptions on GCP

dentech-floss/watermill-opentelemetry-go-extra

Provides support for propagating trace/span id metadata along with a published Watermill message

kahowell/watermill-amqp10

unofficial AMQP 1.0 pubsub for watermill

weiawesome/gimy_clone_api

The stream-media server made by micro-service.

andyollylarkin/watermill-net

Net Pub/Sub for the Watermill project.

logur/integration-watermill

Logur logger integration for Watermill

minghsu0107/GoogleCloud-PubSub

Google Cloud Pub/Sub publisher / subscriber using Watermill.

pog7x/go-rmq-worker-tmpl

Golang RMQ asynchronous worker template

Amf1k/debezium-nats-example

Пример использования Debezium c Postgres и NATS JetStream без использованя фреймворка Apache Kafka Connect.

dentech-floss/publisher

Watermill messaging publisher for GCP, instrumented by OpenTelemetry

dentech-floss/subscriber

Watermill messaging subscriber for http push subscriptions on GCP, instrumented by OpenTelemetry

joerocklin/watermilllogr

stanislav-zeman/event-driven-go

Three Dots Labs Event-Driven course exercises

survivorbat/go-watermill-test-logger

Logger for testing with watermill.

ThreeDotsLabs/watermill-firestore

Firestore Pub/Sub for the Watermill project.