cloudEvent

Documentation

Index

• type CloudEvent
  • func (CloudEvent) AvroRecord() avrotypegen.RecordInfo
• type Message
  • func (Message) AvroRecord() avrotypegen.RecordInfo
• type Metadata
  • func (Metadata) AvroRecord() avrotypegen.RecordInfo

Types

type CloudEvent

type CloudEvent struct {
	Id string `json:"id"`

	// source holds the 		 * source of the message.
	Source      string    `json:"source"`
	Specversion string    `json:"specversion"`
	Time        time.Time `json:"time"`
}

func (CloudEvent) AvroRecord

func (CloudEvent) AvroRecord() avrotypegen.RecordInfo

AvroRecord implements the avro.AvroRecord interface.

type Message

type Message struct {
	Metadata Metadata
}

func (Message) AvroRecord

func (Message) AvroRecord() avrotypegen.RecordInfo

AvroRecord implements the avro.AvroRecord interface.

type Metadata

type Metadata struct {
	CloudEvent CloudEvent
}

func (Metadata) AvroRecord

func (Metadata) AvroRecord() avrotypegen.RecordInfo

AvroRecord implements the avro.AvroRecord interface.