event

Sep 13, 2022

Changes in this version

type SelfDescribingEvent

+ Contexts map[string]interface{}

Aug 21, 2022

Changes in this version

+ type Contexts map[string]interface

+ type Event interface

+ PayloadAsByte func() ([]byte, error)

+ Scan func(input interface{}) error

+ SchemaName func() *string

+ Value func() (driver.Value, error)

+ type Payload map[string]interface

+ func (p *Payload) AsByte() ([]byte, error)

+ type SelfDescribingContext SelfDescribingPayload

+ type SelfDescribingEvent struct

+ Payload SelfDescribingPayload

+ type SelfDescribingPayload struct

+ Data map[string]interface{}

+ Schema string

+ 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)