Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Codec ¶
type Codec struct {
Encoding Encoding
TransportName string
// contains filtered or unexported fields
}
Codec ...
type CodecV1 ¶
type CodecV1 struct {
CodecStructured
TransportName string
Encoding Encoding
}
CodecV1 ...
type CodecV02 ¶
type CodecV02 struct {
CodecStructured
TransportName string
Encoding Encoding
}
CodecV02 ...
type CodecV03 ¶
type CodecV03 struct {
CodecStructured
TransportName string
Encoding Encoding
}
CodecV03 ...
type Encoding ¶
type Encoding int32
Encoding to use for NATS transport.
const ( // Default allows NATS transport implementation to pick. Default Encoding = iota // StructuredV02 is Structured CloudEvents spec v0.2. StructuredV02 // StructuredV03 is Structured CloudEvents spec v0.3. StructuredV03 // StructuredV1 is Structured CloudEvents spec v1.0. StructuredV1 // Unknown is unknown. Unknown )
type EventBridgeMessage ¶
type EventBridgeMessage struct {
DetailType string `json:"detail-type"` // In case of EventBridge, this value is nonempty string
Detail interface{} `json:"detail"` // Message object
}
EventBridgeMessage ...
func DecodeEventBridgeMessage ¶
func DecodeEventBridgeMessage(body []byte) (message *EventBridgeMessage, ok bool)
DecodeEventBridgeMessage ...
type Message ¶
type Message struct {
Body []byte
}
Message ...
func (Message) CloudEventsVersion ¶
CloudEventsVersion ...
type SNSMessage ¶
type SNSMessage struct {
Type string // In case of SNS, the type is "Notification"
Message string // JSON encoded message
}
SNSMessage ...
func DecodeSNSMessage ¶
func DecodeSNSMessage(body []byte) (message *SNSMessage, ok bool)
DecodeSNSMessage ...
Click to show internal directories.
Click to hide internal directories.