sdk-go
sdk-go copied to clipboard
cloudevents
Go SDK for CloudEvents
The Read/Write timeout on the http client is hardcoded to the `DefaultTimeout` of 10 minutes. This does not transition well to longer running processes, e.g. extending the knative service for...
Hi 😄, Currently v2 amqp protocol is making use of Azure/go-amqp version 0.17.0. The package is already in version 1.0.5. This is causing constraints in upgrading the cloudevents package on...
There's a new (well, 12 months old) SDK for interacting with JetStream, package `github.com/nats-io/nats.go/jetstream`. It makes things a bit easier for interacting with JetStream so we want to use it...
Hi, folks! Is it possible to access the special NATS headers on send, for example Nats-Expected-Last-Sequence These headers would allow event sourcing with CloudEvents. The neat thing is that consumers...
We're experiencing a panic due to send on a closed channel here: https://github.com/cloudevents/sdk-go/blob/release-v2.15.2/protocol/kafka_sarama/v2/receiver.go#L80 I've traced this to the fact that the `incoming` channel is closed in SDK managed goroutine here:...
The WithCustomAttributes function currently takes a map as input value. Since map is a pointer value, the pointer is passed to msg.Attributes of the pubsub message and then is used...
It is a bit frustrating when I went over the [MQTT samples](https://github.com/cloudevents/sdk-go/tree/1ed9471c98bdf49bcc1ffe74980c15691beb749f/samples/mqtt). As there is lack of documentation. Providing the sample command like the one below would help and save...
Bumps the bundler group with 1 update in the /docs directory: [nokogiri](https://github.com/sparklemotion/nokogiri). Updates `nokogiri` from 1.16.2 to 1.16.5 Release notes Sourced from nokogiri's releases. v1.16.5 / 2024-05-13 Security [CRuby] Vendored...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
Bumps the go_modules group with 1 update in the /observability/opencensus/v2 directory: [golang.org/x/net](https://github.com/golang/net). Bumps the go_modules group with 1 update in the /protocol/kafka_sarama/v2 directory: [golang.org/x/net](https://github.com/golang/net). Bumps the go_modules group with 1...