cloudevents

Documentation

Index

• 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)
• type CloudeventsInput
  • func (i *CloudeventsInput) EnvelopeBuilder(c *gin.Context, conf *config.Config, metadata *meta.CollectorMeta) []envelope.Envelope
  • func (i *CloudeventsInput) Handler(m manifold.Manifold, conf config.Config, metadata *meta.CollectorMeta) gin.HandlerFunc
  • func (i *CloudeventsInput) Initialize(engine *gin.Engine, manifold *manifold.Manifold, conf *config.Config, ...) error
  • func (i *CloudeventsInput) SquawkboxHandler(m manifold.Manifold, conf config.Config, metadata *meta.CollectorMeta) 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)

type CloudeventsInput

type CloudeventsInput struct{}

func (*CloudeventsInput) EnvelopeBuilder

func (i *CloudeventsInput) EnvelopeBuilder(c *gin.Context, conf *config.Config, metadata *meta.CollectorMeta) []envelope.Envelope

func (*CloudeventsInput) Handler

func (i *CloudeventsInput) Handler(m manifold.Manifold, conf config.Config, metadata *meta.CollectorMeta) gin.HandlerFunc

func (*CloudeventsInput) Initialize

func (i *CloudeventsInput) Initialize(engine *gin.Engine, manifold *manifold.Manifold, conf *config.Config, metadata *meta.CollectorMeta) error

func (*CloudeventsInput) SquawkboxHandler

func (i *CloudeventsInput) SquawkboxHandler(m manifold.Manifold, conf config.Config, metadata *meta.CollectorMeta) gin.HandlerFunc