cloudevents

README

transfer the message with cloudevents protocol

Documentation

Index

• type CloudeventsPlugin
  • func (c *CloudeventsPlugin) FromCloudEvent(event *v2.Event) (interface{}, error)
  • func (c *CloudeventsPlugin) ProtocolType() string
  • func (c *CloudeventsPlugin) Setup(name string, dec plugin.Decoder) error
  • func (c *CloudeventsPlugin) ToCloudEvent(msg interface{}) (*v2.Event, error)
  • func (c *CloudeventsPlugin) ToCloudEvents(msg interface{}) ([]*v2.Event, error)
  • func (c *CloudeventsPlugin) Type() string

Types

type CloudeventsPlugin

type CloudeventsPlugin struct {
}

CloudeventsPlugin CloudEvents protocol adaptor used to transform CloudEvents message to CloudEvents message.

func (*CloudeventsPlugin) FromCloudEvent

func (c *CloudeventsPlugin) FromCloudEvent(event *v2.Event) (interface{}, error)

func (*CloudeventsPlugin) ProtocolType

func (c *CloudeventsPlugin) ProtocolType() string

func (*CloudeventsPlugin) Setup

func (c *CloudeventsPlugin) Setup(name string, dec plugin.Decoder) error

func (*CloudeventsPlugin) ToCloudEvent

func (c *CloudeventsPlugin) ToCloudEvent(msg interface{}) (*v2.Event, error)

func (*CloudeventsPlugin) ToCloudEvents

func (c *CloudeventsPlugin) ToCloudEvents(msg interface{}) ([]*v2.Event, error)

func (*CloudeventsPlugin) Type

func (c *CloudeventsPlugin) Type() string