cloudevents

type BinaryLoader interface {
	// FromHeaders copies data from the supplied HTTP headers into the object.
	// Values will be defaulted if necessary.
	FromHeaders(in http.Header) error
}

type BinarySender interface {
	// AsHeaders converts this EventContext to a set of HTTP headers.
	AsHeaders() http.Header
}

type ContextType interface {
	SendContext
	LoadContext
}

type EventContext = V01EventContext

type HTTPMarshaller interface {
	FromRequest(data interface{}, r *http.Request) (*EventContext, error)
	NewRequest(urlString string, data interface{}, context SendContext) (*http.Request, error)
}

type LoadContext interface {
	StructuredLoader
	BinaryLoader

	// AsV01 provides a translation from whatever the "native" encoding of the
	// CloudEvent was to the equivalent in v0.1 field names, moving fields to or
	// from extensions as necessary.
	AsV01() V01EventContext
}

type Mux map[string]*handler

type SendContext interface {
	StructuredSender
	BinarySender
}

type StructuredLoader interface {
	// FromJSON assumes that the object has already been decoded into a raw map
	// from string to json.RawMessage, because this is needed to extract the
	// CloudEvents version.
	FromJSON(map[string]json.RawMessage) error
}

type StructuredSender interface {
	// AsJSON encodes the object into a map from string to JSON data, which
	// allows additional keys to be encoded later.
	AsJSON() (map[string]json.RawMessage, error)
	// DataContentType returns the MIME content type for encoding data.
	DataContentType() string
}

type V01EventContext struct {
	// The version of the CloudEvents specification used by the event.
	CloudEventsVersion string `json:"cloudEventsVersion,omitempty"`
	// ID of the event; must be non-empty and unique within the scope of the producer.
	EventID string `json:"eventID"`
	// Timestamp when the event happened.
	EventTime time.Time `json:"eventTime,omitempty"`
	// Type of occurrence which has happened.
	EventType string `json:"eventType"`
	// The version of the `eventType`; this is producer-specific.
	EventTypeVersion string `json:"eventTypeVersion,omitempty"`
	// A link to the schema that the `data` attribute adheres to.
	SchemaURL string `json:"schemaURL,omitempty"`
	// A MIME (RFC 2046) string describing the media type of `data`.
	// TODO: Should an empty string assume `application/json`, or auto-detect the content?
	ContentType string `json:"contentType,omitempty"`
	// A URI describing the event producer.
	Source string `json:"source"`
	// Additional metadata without a well-defined structure.
	Extensions map[string]interface{} `json:"extensions,omitempty"`
}