Documentation ¶
Index ¶
- type Event
- type Payload
- type SelfDescribingContext
- type SelfDescribingEvent
- type SelfDescribingPayload
- func (e SelfDescribingPayload) AsByte() ([]byte, error)
- func (e SelfDescribingPayload) AsMap() (map[string]interface{}, error)
- func (e SelfDescribingPayload) PayloadAsByte() ([]byte, error)
- func (e SelfDescribingPayload) Scan(input interface{}) error
- func (e SelfDescribingPayload) SchemaName() *string
- func (e SelfDescribingPayload) Value() (driver.Value, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SelfDescribingContext ¶
type SelfDescribingContext SelfDescribingPayload
type SelfDescribingEvent ¶
type SelfDescribingEvent struct { Contexts map[string]interface{} `json:"contexts"` Payload SelfDescribingPayload `json:"payload"` }
type SelfDescribingPayload ¶
type SelfDescribingPayload struct { Schema string `json:"schema"` Data map[string]interface{} `json:"data"` }
func (SelfDescribingPayload) AsByte ¶
func (e SelfDescribingPayload) AsByte() ([]byte, error)
func (SelfDescribingPayload) AsMap ¶
func (e SelfDescribingPayload) AsMap() (map[string]interface{}, error)
func (SelfDescribingPayload) PayloadAsByte ¶
func (e SelfDescribingPayload) PayloadAsByte() ([]byte, error)
func (SelfDescribingPayload) Scan ¶
func (e SelfDescribingPayload) Scan(input interface{}) error
func (SelfDescribingPayload) SchemaName ¶
func (e SelfDescribingPayload) SchemaName() *string
Click to show internal directories.
Click to hide internal directories.