sdk-go

sdk-go copied to clipboard

Feature request: Send cloud event to AWS sns

2

It seems like we can only send the event to the Google pub/sub service. any plan to support Aws sns service as well?

pingsutw

Could we expose sdkToProto function

1

I want to convert the CloudEvent object to CloudEvent proto, but the SDK doesn't expose this [function](https://github.com/cloudevents/sdk-go/blob/a302fc5e5e6a462237f6166905c725921d4da131/binding/format/protobuf/v2/protobuf.go#L76). I've to do the following steps to get proto. ```golang eventProto := cloudeventsModel.CloudEvent{}...

pingsutw

PubSub subsequent messages not properly ordered by key

2

https://github.com/cloudevents/sdk-go/blob/7601392008ad787e9f27cf1d7898ff14fef1b236/protocol/pubsub/v2/protocol.go#L233 I tested pubsub ordering key with this library but I found an issue. When you send 3 or more messages, with same ordering key, receiver only waits for first...

rriolobos

Need to wrap `sarama.AsyncProducer` for tracing (OpenTelemetry/Datadog)

8

I need to wrap the `sarama.AsyncProducer`, which is an un-exported field in `Sender` struct. Is this possible to do?

rahulchheda

Retries don't work for HTTP POST resquests with a body

2

I'm using Tekton and I believe I've found a bug in this library, since it's used for sending [CloudEvents based on Kubernetes events](https://github.com/tektoncd/pipeline/blob/1f5980f8c8a05b106687cfa3e5b3193c213cb66e/pkg/reconciler/events/cloudevent/cloud_event_controller.go#L144). By default, it uses the ExponentialBackoff retry...

aruiz14

Trying to get the OpenTelemetry ObservabilityService working with PubSub. From what I can tell you have to call ```go otelObs.InjectDistributedTracingExtension(ctx, event) ``` before sending an event and then call ```go...

owenhaynes

Enable Trace Propagation

8

It looks like the Go SDK doesn't have any ability to propagate the `traceparent` HTTP header to the CE SDK client. The SDK only receives `ce-traceparent` headers, which is not...

grant

Selective `isRetriableFunc` in `cecontext`

3

This was discussed in https://github.com/knative/eventing/issues/5884 as one solution to make `isRetriableFunc` and custom status codes configurable on a per request basis via `cecontext.WithRetryParams`. This is helpful in at least two...

embano1

OptionsHandlerFn is set to DeleteHandlerFn in WithDefaultOptionsHandlerFunc

2

https://github.com/cloudevents/sdk-go/blob/1170e89edb9b504a806f2c6a26563c3c26b68276/v2/protocol/http/options.go#L251 Can you please explain why `OptionsHandlerFn` is set to `DeleteHandlerFn` in `WithDefaultOptionsHandlerFunc` Thanks in advance

abhradeepkundu

Implement SendCloser on gochan.Protocol

2

I'm using the `gochan` protocol for some internal processing of events. I've built a series of `cloudevents.Client` like so: 1. Client `#1` listens on HTTP for events 2. For each...

dan-j