MCPcopy Index your code
hub / github.com/ThreeDotsLabs/watermill-redisstream

github.com/ThreeDotsLabs/watermill-redisstream @v1.4.5

Chat with this repo
repository ↗ · DeepWiki ↗ · release v1.4.5 ↗ · + Follow
53 symbols 190 edges 7 files 3 documented · 6% 1 cross-repo links updated 56d agov1.4.5 · 2025-11-28★ 43
What it actually does AI analysis from the code graph — generated when you open this
loading…
README

Watermill Redis Pub/Sub

CI Status Go Report Card

This is Pub/Sub for the Watermill project.

See DEVELOPMENT.md for more information about running and testing.

Watermill is a Go library for working efficiently with message streams. It is intended for building event driven applications, enabling event sourcing, RPC over messages, sagas and basically whatever else comes to your mind. You can use conventional pub/sub implementations like Kafka or RabbitMQ, but also HTTP or MySQL binlog if that fits your use case.

All Pub/Sub implementations can be found at https://watermill.io/pubsubs/.

Documentation: https://watermill.io/

Getting started guide: https://watermill.io/docs/getting-started/

Issues: https://github.com/ThreeDotsLabs/watermill/issues

Contributing

All contributions are very much welcome. If you'd like to help with Watermill development, please see open issues and submit your pull request via GitHub.

Support

If you didn't find the answer to your question in the documentation, feel free to ask us directly!

Please join us on the #watermill channel on the Three Dots Labs Discord.

License

MIT License

Extension points exported contracts — how you extend this code

Core symbols most depended-on inside this repo

Shape

Function 21
Method 21
Struct 8
Interface 3

Languages

Go100%

Modules by API surface

pkg/redisstream/pubsub_test.go17 symbols
pkg/redisstream/subscriber.go15 symbols
pkg/redisstream/marshaller.go8 symbols
pkg/redisstream/publisher.go7 symbols
pkg/redisstream/marshaller_test.go4 symbols
pkg/redisstream/pubsub_stress_test.go1 symbols
pkg/redisstream/pubsub_bench_test.go1 symbols

Used by 1 indexed graphs manifest dependencies, hub-wide

For agents

$ claude mcp add watermill-redisstream \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact

Ask about this repo answers extend the page