in client/start.go [70:88]
func sendCE(url string, e cloudevents.Event) error {
ctx := cloudevents.ContextWithTarget(context.Background(), url)
p, err := cloudevents.NewHTTP()
if err != nil {
return fmt.Errorf("failed to create protocol: %v", err)
}
c, err := cloudevents.NewClient(p, cloudevents.WithTimeNow(), cloudevents.WithUUIDs())
if err != nil {
return fmt.Errorf("failed to create client, %v", err)
}
res := c.Send(ctx, e)
if !cloudevents.IsACK(res) {
return fmt.Errorf("failed to send CloudEvent: %v", res)
}
return nil
}