Golang SDK to emit CDEvents.
The SDK can be used to create CDEvents and send them as CloudEvents, as well as parse a received CloudEvent into a CDEvent.
Add the module as dependency using go mod:
go get github.com/cdevents/sdk-go
And import the module in your code corresponding to the desired version of the specification. For CDEvents v0.4.x, use:
import cdeventsv04 "github.com/cdevents/sdk-go/pkg/api/v04"
To create a CDEvent, for instance a pipelineRun queued one:
func main() {
// Create the base event
event, err := cdeventsv04.NewPipelineRunQueuedEvent()
if err != nil {
log.Fatalf("could not create a cdevent, %v", err)
}
// Set the required context fields
event.SetSubjectId("myPipelineRun1")
event.SetSource("my/first/cdevent/program")
// Set the required subject fields
event.SetSubjectPipelineName("myPipeline")
event.SetSubjectUrl("https://example.com/myPipeline")
}
Import the modules in your code
import cdevents "github.com/cdevents/sdk-go/pkg/api"
import cloudevents "github.com/cloudevents/sdk-go/v2"
To send a CDEvent as CloudEvent:
func main() {
// (...) set the event first
ce, err := cdevents.AsCloudEvent(event)
// Set send options
ctx := cloudevents.ContextWithTarget(context.Background(), "http://localhost:8080/")
ctx = cloudevents.WithEncodingBinary(ctx)
c, err := cloudevents.NewClientHTTP()
if err != nil {
log.Fatalf("failed to create client, %v", err)
}
// Send the CloudEvent
// c is a CloudEvent client
if result := c.Send(ctx, *ce); cloudevents.IsUndelivered(result) {
log.Fatalf("failed to send, %v", result)
}
}
See the CloudEvents docs as well.
More examples are available in the docs folder. Online API Reference:
If you would like to contribute, see our development guide.