inputcloudevents

Documentation

Index

• Constants
• func BuildEnvelopesFromRequest(c *gin.Context, conf *config.Config, m *meta.CollectorMeta) []envelope.Envelope
• func Handler(h params.Handler) gin.HandlerFunc
• type CloudEvent
  • func (e CloudEvent) AsByte() ([]byte, error)
  • func (e CloudEvent) AsMap() (map[string]interface{}, error)
  • func (e CloudEvent) PayloadAsByte() ([]byte, error)
  • func (e CloudEvent) Scan(input interface{}) error
  • func (e CloudEvent) SchemaName() *string
  • func (e CloudEvent) Value() (driver.Value, error)

Constants

const (
	SQUAWK_PATH = "/squawk/cloudevents"
)

Functions

func BuildEnvelopesFromRequest

func BuildEnvelopesFromRequest(c *gin.Context, conf *config.Config, m *meta.CollectorMeta) []envelope.Envelope

func Handler

func Handler(h params.Handler) gin.HandlerFunc

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"`
	Datab64         string                 `json:"datab64"`
}

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

func (e CloudEvent) Scan(input interface{}) error

func (CloudEvent) SchemaName

func (e CloudEvent) SchemaName() *string

func (CloudEvent) Value

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