events

type Event struct {
	Payload     map[string]interface{} `json:"payload"`
	PayloadType string                 `json:"payloadType"`
	ID          string                 `json:"id"`
}

type Events interface {
	// Topic - Retrieve a Topic reference
	Topic(name string) Topic
	// Topics - Retrievs a list of available Topic references
	Topics() ([]Topic, error)
}

type PublishOption = func(*v1.EventPublishRequest)

type Topic interface {
	// Name returns the Topic name.
	Name() string

	// Publish will publish the provided events on the topic.
	Publish(context.Context, *Event, ...PublishOption) (*Event, error)
}