Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAdapter ¶
func NewAdapter(ctx context.Context, envAcc pkgadapter.EnvConfigAccessor, ceClient cloudevents.Client) pkgadapter.Adapter
NewAdapter satisfies pkgadapter.AdapterConstructor.
func NewEnvConfig ¶
func NewEnvConfig() pkgadapter.EnvConfigAccessor
NewEnvConfig satisfies pkgadapter.EnvConfigConstructor.
Types ¶
type Message ¶
type Message struct {
*azservicebus.ReceivedMessage
LockToken *string
}
Message is a servicebus.ReceivedMessage with some selected fields shadowed for improved serialization.
type MessageProcessor ¶
type MessageProcessor interface {
Process(*Message) ([]*cloudevents.Event, error)
}
MessageProcessor converts an Service Bus message to a CloudEvent.
type MessageWithRawJSONData ¶
type MessageWithRawJSONData struct {
Body json.RawMessage
*Message
}
MessageWithRawJSONData is an ReceivedMessage with RawMessage-typed JSON data.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.