event

Documentation

Index

• type Contexts
• type Event
• type Payload
  • func (p *Payload) AsByte() ([]byte, error)
• 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)

Types

type Contexts

type Contexts map[string]interface{}

type Event

type Event interface {
	SchemaName() *string
	PayloadAsByte() ([]byte, error)
	Value() (driver.Value, error)
	Scan(input interface{}) error
}

type Payload

type Payload map[string]interface{}

func (*Payload) AsByte

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

type SelfDescribingContext

type SelfDescribingContext SelfDescribingPayload

type SelfDescribingEvent

type SelfDescribingEvent struct {
	Contexts `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

func (SelfDescribingPayload) Value

func (e SelfDescribingPayload) Value() (driver.Value, error)