Versions in this module Expand all Collapse all v0 v0.1.5 Jun 27, 2020 Changes in this version + type Codec struct + Encoding Encoding + TransportName string + func (c *Codec) Decode(ctx context.Context, msg transport.Message) (*cloudevents.Event, error) + func (c *Codec) Encode(ctx context.Context, e cloudevents.Event) (transport.Message, error) + type CodecStructured struct + Encoding Encoding + type CodecV02 struct + Encoding Encoding + TransportName string + func (v CodecV02) Decode(ctx context.Context, msg transport.Message) (*cloudevents.Event, error) + func (v CodecV02) Encode(ctx context.Context, e cloudevents.Event) (transport.Message, error) + type CodecV03 struct + Encoding Encoding + TransportName string + func (v CodecV03) Decode(ctx context.Context, msg transport.Message) (*cloudevents.Event, error) + func (v CodecV03) Encode(ctx context.Context, e cloudevents.Event) (transport.Message, error) + type CodecV1 struct + Encoding Encoding + TransportName string + func (v CodecV1) Decode(ctx context.Context, msg transport.Message) (*cloudevents.Event, error) + func (v CodecV1) Encode(ctx context.Context, e cloudevents.Event) (transport.Message, error) + type Encoding int32 + const Default + const StructuredV02 + const StructuredV03 + const StructuredV1 + const Unknown + func (e Encoding) String() string + func (e Encoding) Version() string + type EventBridgeMessage struct + Detail interface{} + DetailType string + func DecodeEventBridgeMessage(body []byte) (message *EventBridgeMessage, ok bool) + func (m *EventBridgeMessage) GetBody() []byte + func (m *EventBridgeMessage) IsValid() bool + type Message struct + Body []byte + func (m Message) CloudEventsVersion() string + type SNSMessage struct + Message string + Type string + func DecodeSNSMessage(body []byte) (message *SNSMessage, ok bool) + func (m *SNSMessage) GetBody() []byte + func (m *SNSMessage) IsNotification() bool
Go to main page