sdk-go
sdk-go copied to clipboard
cloudevents
Go SDK for CloudEvents
@zhaojizhuang should we deprecate the nats and stan packages in favor of jetstream?
We are using cloudevents SDK from our k8s projects. It would be nice if we could just use one logging library. What do you think about using https://github.com/go-logr/logr as the...
If, say,`event := cloudevents.NewEvent("2.0")` is used to make `event` and then `event.SetType("foo")` is called, this causes a nil pointer exception because the internal context is nil. I would expect to...
Starting in v2.4.1, the EventReceiver ServeHTTP handler seems to sometimes return before the user provided function that is called by the receiveInvoker; cancelling the request context passed to the user...
Ref: https://github.com/cloudevents/spec/blob/master/extensions/sequence.md
When calling close on protocol ``` func (t *Protocol) Close(ctx context.Context) (err error) { ```` The code goes on an infinite loop ``` client/client.go line 244 if err != nil...
``` === RUN TestSendStructuredMessagedToStructures/regular_subscriber/Event{"data":"hello","datacontenttype":"text/json","dataschema":"http://example.com/schema","exbinary":"AAECAw==","exbool":true,"exint":42,"exstring":"exstring","extime":"2020-03-21T12:34:56.78Z","exurl":"http://example.com/source","id":"full-event-0","source":"http://example.com/source","specversion":"1.0","subject":"topic","time":"2020-03-21T12:34:56.78Z","type":"com.example.FullEvent"} coverage: [no statements] panic: test timed out after 5m0s goroutine 15 [running]: testing.(*M).startAlarm.func1() /opt/hostedtoolcache/go/1.14.12/x64/src/testing/testing.go:1514 +0x11c created by time.goFunc /opt/hostedtoolcache/go/1.14.12/x64/src/time/sleep.go:168 +0x52 goroutine 1 [chan receive]: testing.(*T).Run(0xc0001b7560, 0xbdc7fb,...
Hi! When we create a new protocol, we set address and node. Node - is a message queue in broker. I use rabbitMQ, and want that new protocol create a...
