Documentation
¶
Index ¶
- type CloudEvent
- 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(routerGroup *gin.RouterGroup, manifold *manifold.Manifold, conf *config.Config, ...) error
- func (i *CloudeventsInput) SquawkboxHandler(m manifold.Manifold, conf config.Config, metadata *meta.CollectorMeta) gin.HandlerFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
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(routerGroup *gin.RouterGroup, 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
Source Files
Click to show internal directories.
Click to hide internal directories.