messaging

type CloudEvent struct {

	// ID identifies the event. Producers MUST ensure that source + id is unique for each distinct event. If a duplicate
	// event is re-sent (e.g. due to a network error) it MAY have the same id. Consumers MAY assume that Events with
	// identical source and id are duplicates.
	ID string

	// Source identifies the context in which an event happened.
	Source string

	// SpecVersion is the version of the CloudEvents specification which the event uses.
	SpecVersion string

	// Type contains a value describing the type of event related to the originating occurrence.
	Type string

	// Data is the payload for the event.
	// * []byte will be serialized and deserialized as []byte.
	// * Any other type will be serialized to a JSON object and deserialized into
	//   a []byte, containing the JSON text.
	//
	// To deserialize into your chosen type:
	//
	//   var yourData *YourType
	//   json.Unmarshal(cloudEvent.Data.([]byte), &yourData)
	//
	Data any

	// DataContentType is the content type of [Data] value (ex: "text/xml")
	DataContentType *string

	// DataSchema identifies the schema that Data adheres to.
	DataSchema *string

	// Extensions are attributes that are serialized as siblings to attributes like Data.
	Extensions map[string]any

	// Subject of the event, in the context of the event producer (identified by Source).
	Subject *string

	// Time represents the time this event occurred.
	Time *time.Time
}

type CloudEventOptions struct {
	// DataContentType is the content type of [Data] value (ex: "text/xml")
	DataContentType *string

	// DataSchema identifies the schema that Data adheres to.
	DataSchema *string

	// Extensions are attributes that are serialized as siblings to attributes like Data.
	Extensions map[string]any

	// Subject of the event, in the context of the event producer (identified by Source).
	Subject *string

	// Time represents the time this event occurred.
	// Defaults to time.Now().UTC()
	Time *time.Time
}