cloudevents

Documentation

Index

• type CloudEvent
  • func BuildEvent(payload gjson.Result) (CloudEvent, error)
  • func (e CloudEvent) AsByte() ([]byte, error)
  • func (e CloudEvent) AsMap() (map[string]interface{}, error)
  • func (e CloudEvent) PayloadAsByte() ([]byte, error)
  • func (e CloudEvent) Protocol() string
  • func (e CloudEvent) Schema() *string

Types

type CloudEvent

type CloudEvent struct {
	Id              string                 `json:"id"`
	Source          string                 `json:"source"`
	SpecVersion     string                 `json:"specversion"`
	Type            string                 `json:"type"`
	DataContentType string                 `json:"datacontenttype"`
	DataSchema      string                 `json:"dataschema"`
	Subject         *string                `json:"subject"`
	Time            time.Time              `json:"time"`
	Data            map[string]interface{} `json:"data"`
	DataBase64      string                 `json:"dataBase64,omitempty"`
}

func BuildEvent

func BuildEvent(payload gjson.Result) (CloudEvent, error)

func (CloudEvent) AsByte

func (e CloudEvent) AsByte() ([]byte, error)

func (CloudEvent) AsMap

func (e CloudEvent) AsMap() (map[string]interface{}, error)

func (CloudEvent) PayloadAsByte

func (e CloudEvent) PayloadAsByte() ([]byte, error)

func (CloudEvent) Protocol

func (e CloudEvent) Protocol() string

func (CloudEvent) Schema

func (e CloudEvent) Schema() *string