watermill
watermill copied to clipboard
ThreeDotsLabs
Building event-driven applications the easy way in Go.
Hello, I've been testing Watermill with one of our services and I've noticed constant memory increase while using it (slight, but still there). After checking code in my service, I...
The CQRS part has a CommandBus && EventBus but doesn't have QueryBus https://watermill.io/docs/cqrs/ is it planned to add QueryBus? or is there a way to return interface{} from the CommandBus?
Add a new pull subscribe option and target separately using eg https://natsbyexample.com/examples/jetstream/api-migration/go I expect existing callback-based implementations will continue to work at least until v2 of the nats.go client is...
My use case is reading kafka message using segment-io kafka driver and publishing to watermill using GoChannel. One day I got a kafka topic blocking. After read watermill code, I...
This appears to be the same issue as https://github.com/Shopify/sarama/issues/1192? And it can be fixed by doing something like https://github.com/IBM/sarama/commit/0151486eeb29f538508f313a3c4f9c1c11ee5e04 ?
Our use-case is using Durable subscriptions with Queues and Kubernetes pods running watermill using watermill-nats with jetstream support. When we started playing with scale down functionality we saw weird behaviour...
I noticed this thing while implementing some changes in my project, regarding https://github.com/ThreeDotsLabs/watermill/issues/378. It has not been a problem before, since the only date column in the messages table is...
Noticed working on benchmarks that auto provisioning is especially slow on the publish side. I thought the NATS client did some caching of stream lookups but maybe not. It should...
After follwing the standard setup procedure, running `make update_watermill` on MacOS Monterey output: ``` go get -u github.com/ThreeDotsLabs/watermill go mod tidy sed -i '\|go 1\.|d' go.mod sed: 1: "go.mod": extra...
Metadata
Owner
Metadata
Building event-driven applications the easy way in Go.