azservicebus

Documentation

Index

• func NewAdapter(ctx context.Context, envAcc pkgadapter.EnvConfigAccessor, ...) pkgadapter.Adapter
• func NewEnvConfig() pkgadapter.EnvConfigAccessor
• type Message
• type MessageProcessor
• type MessageWithRawJSONData

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.