watermill
watermill copied to clipboard
Building event-driven applications the easy way in Go.
Hi, watermil-kafka allows tracing with OTEL. Seems like it is very hard coded and baked in. I would love to be able to trace with another tracer (e.g. Datadog's ddtrace)....
https://github.com/ThreeDotsLabs/watermill/blob/master/_examples/real-world-examples/server-sent-events/docker-compose.yml Uses soon to be deprecated Nats streaming
Hello! We can customize subscription settings when creating it. But for existing subscription will be used current configuration from Google cloud. We cannot customize them if needed. https://github.com/ThreeDotsLabs/watermill-googlecloud/blob/8bfa935bf8e7c92b9836cafbc3a1587b452f3e2a/pkg/googlecloud/subscriber.go#L377 Google pub/sub...
Bumps [golang.org/x/net](https://github.com/golang/net) from 0.5.0 to 0.7.0. Commits 8e2b117 http2/hpack: avoid quadratic complexity in hpack decoding 547e7ed http2: avoid referencing ResponseWrite.Write parameter after returning 39940ad html: parse comments per HTML spec...
hey, we got logs about panic while closing subscriber. our system runs on GKE. and it looks to raise panic in deploying on GKE. ``` panic: close of closed channel...
Bumps [golang.org/x/net](https://github.com/golang/net) from 0.5.0 to 0.7.0. Commits 8e2b117 http2/hpack: avoid quadratic complexity in hpack decoding 547e7ed http2: avoid referencing ResponseWrite.Write parameter after returning 39940ad html: parse comments per HTML spec...
Package jsonendpoint provides a generic adapter that converts a validated JSON request into a [message.Message] published to a certain topic. Use together with an HTTP router to build gateways to...
Hey. Maybe it's not an issue, but is there a support for HTTP pub/sub with Google Cloud? What I mean is something like this: https://cloud.google.com/run/docs/tutorials/pubsub Would be nice to add...
no subscriber should return an error when publishing