events

Documentation

Index

• func CreateArtifactPubEvent(ctx context.Context, key string) (*cloudevents.Event, error)
• func DecodeEventSubject(ctx context.Context, collectedEvent []byte) (string, error)
• func GetKey(blob []byte) string

Functions

func CreateArtifactPubEvent

func CreateArtifactPubEvent(ctx context.Context, key string) (*cloudevents.Event, error)

CreateArtifactPubEvent creates a NewArtifactPublishedEvent CDEvent that is published as a CloudEvent. The key is the sha256 of the *processor.Document bytes that will be used to retrieve the processor.Document stored in the blob store. TODO (pxp928): change to use URI Reference field once the PR merges: https://github.com/cdevents/spec/pull/171

func DecodeEventSubject

func DecodeEventSubject(ctx context.Context, collectedEvent []byte) (string, error)

DecodeEventSubject takes in the collectedEvent bytes and converts it back into a CloudEvent to retrieve the necessary fields. The returned value is the subject of the event.

func GetKey

func GetKey(blob []byte) string