events

type CloudEvent struct {
	// Mandatory, e.g. "user.created"
	EventType string `json:"eventType" validate:"required,max=128,eventtype"`
	// Optional, e.g. "VMODL6.5"
	EventTypeVersion string `json:"eventTypeVersion,omitempty" validate:"omitempty,min=1"`
	// Mandatory, fixed to "0.1"
	CloudEventsVersion string `json:"cloudEventsVersion" validate:"eq=0.1"`
	// Mandatory, e.g. "vcenter1.corp.local"
	Source string `json:"source" validate:"required"`
	// Mandatory, e.g. UUID or "43252363". Must be unique for this Source
	EventID string `json:"eventID" validate:"required"`
	// Optional, Timestamp in RFC 3339 format, e.g. "1985-04-12T23:20:50.52Z"
	EventTime time.Time `json:"eventTime,omitempty" validate:"-"`
	// Optional, if specified must be a valid URI
	SchemaURL string `json:"schemaURL,omitempty" validate:"omitempty,uri"`
	// Optional, if specified must be a valid mime type, e.g. "application/json"
	ContentType string `json:"contentType,omitempty" validate:"omitempty,min=1"`
	// Optional, key-value dictionary for use by Dispatch
	Extensions CloudEventExtensions `json:"extensions,omitempty" validate:"omitempty,min=1"`

	// Event payload
	Data json.RawMessage `json:"data" validate:"omitempty"`
}

type CloudEventExtensions map[string]interface{}

type Handler func(context.Context, *CloudEvent)

type StreamParser interface {
	Parse(io.Reader) ([]CloudEvent, error)
}

type Subscription interface {
	GetTopic() string
	Unsubscribe() error
	GetOrganization() string
}

type Transport interface {

	// Publish publishes the event using the underlying transport
	Publish(ctx context.Context, event *CloudEvent, topic string, organization string) error

	// Subscribe takes a handler to run on every event received on topic. Returns a cancelable Subscription
	Subscribe(ctx context.Context, topic string, organization string, handler Handler) (Subscription, error)
	Close()
}

type Validator interface {
	Validate(event *CloudEvent) error
}