From d2451e23b50f73d27e74b132e08b1fe2e071a202 Mon Sep 17 00:00:00 2001 From: Hao-Ming Hsu <50090692+minghsu0107@users.noreply.github.com> Date: Fri, 3 Feb 2023 00:17:58 +0800 Subject: [PATCH 1/2] Update README.md --- README.md | 1 + 1 file changed, 1 insertion(+) diff --git a/README.md b/README.md index 1f66074fc..dfd7650af 100644 --- a/README.md +++ b/README.md @@ -99,6 +99,7 @@ Supported Pub/Subs: - io.Reader/io.Writer Pub/Sub [(`github.com/ThreeDotsLabs/watermill-io`)](https://github.com/ThreeDotsLabs/watermill-io/) - Kafka Pub/Sub [(`github.com/ThreeDotsLabs/watermill-kafka/v2`)](https://github.com/ThreeDotsLabs/watermill-kafka/) - NATS Pub/Sub [(`github.com/ThreeDotsLabs/watermill-nats`)](https://github.com/ThreeDotsLabs/watermill-nats/) +- Redis Stream Pub/Sub [(`github.com/ThreeDotsLabs/watermill-redisstream`)](https://github.com/ThreeDotsLabs/watermill-redisstream/) - SQL Pub/Sub [(`github.com/ThreeDotsLabs/watermill-sql`)](https://github.com/ThreeDotsLabs/watermill-sql/) From aaf6310d87ed84a4216ab7ad4ad87da9b2a34e9c Mon Sep 17 00:00:00 2001 From: minghsu0107 Date: Fri, 3 Feb 2023 10:44:41 +0800 Subject: [PATCH 2/2] update redis stream doc --- docs/content/pubsubs/redisstream.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/docs/content/pubsubs/redisstream.md b/docs/content/pubsubs/redisstream.md index 760e3eec0..310a52ec7 100644 --- a/docs/content/pubsubs/redisstream.md +++ b/docs/content/pubsubs/redisstream.md @@ -10,7 +10,7 @@ toc = false ### Redis Stream -Redis is a the open source, in-memory data store used by millions of developers. Redis stream is a data structure that acts like an append-only log in Redis. We are providing Pub/Sub implementation based on [redis/go-redis](https://github.com/redis/go-redis). +Redis is the open source, in-memory data store used by millions of developers. Redis stream is a data structure that acts like an append-only log in Redis. We are providing Pub/Sub implementation based on [redis/go-redis](https://github.com/redis/go-redis). ### Installation @@ -69,7 +69,7 @@ Example: #### Marshaler -Watermill's messages cannot be directly sent to Redis - they need to be marshaled. You can implement your marshaler or use default implementation. +Watermill's messages cannot be directly sent to Redis - they need to be marshaled. You can implement your marshaler or use default implementation. The default implementation uses [MessagePack](https://msgpack.org/index.html) for efficient serialization. {{% render-md %}} {{% load-snippet-partial file="src-link/watermill-redisstream/pkg/redisstream/marshaller.go" first_line_contains="const UUIDHeaderKey" last_line_contains="type DefaultMarshallerUnmarshaller" padding_after="0" %}}