messaging

Documentation

Index

• Constants
• type ExecuteInvokedOperation
• type MessageHandlerContext
  • func (c *MessageHandlerContext) Context() context.Context
• type MessageReceiver
  • func NewServiceBusReceiver(handler any, credential azcore.TokenCredential, ...) (MessageReceiver, error)
• type MessageReceiverOptions
• type MessageSender
  • func NewServiceBusMessageSender(credential azcore.TokenCredential, options MessageSenderOptions) (MessageSender, error)
• type MessageSenderOptions
• type QueueName
• type SendMessageResult
• type ServiceBusMessageHandler
  • func NewServiceMessageHandler(handler any) (ServiceBusMessageHandler, error)
• type ServiceBusMessageReceiverOptions

Constants

const DefaultMaxMessages = 10

const MessageHandlerMethodName = "Handle"

Types

type ExecuteInvokedOperation

type ExecuteInvokedOperation struct {
	OperationId uuid.UUID `json:"operationId"`
}

this represents the message (command) that is sent to the operator to be executed

type MessageHandlerContext

type MessageHandlerContext struct {
	ReceivedMessage *azservicebus.ReceivedMessage
	// contains filtered or unexported fields
}

func (*MessageHandlerContext) Context

func (c *MessageHandlerContext) Context() context.Context

type MessageReceiver

type MessageReceiver interface {
	Start()
	Stop()
	GetName() string
}

func NewServiceBusReceiver

func NewServiceBusReceiver(handler any, credential azcore.TokenCredential, options ServiceBusMessageReceiverOptions) (MessageReceiver, error)

type MessageReceiverOptions

type MessageReceiverOptions struct {
	QueueName string
}

type MessageSender

type MessageSender interface {
	Send(ctx context.Context, queueName string, messages ...any) ([]SendMessageResult, error)
	EnsureTopology(ctx context.Context, queueName string) error
}

func NewServiceBusMessageSender

func NewServiceBusMessageSender(credential azcore.TokenCredential, options MessageSenderOptions) (MessageSender, error)

type MessageSenderOptions

type MessageSenderOptions struct {
	SubscriptionId          string
	Location                string
	ResourceGroupName       string
	FullyQualifiedNamespace string
}

type QueueName

type QueueName string

const (
	QueueNameEvents     QueueName = "events"
	QueueNameOperations QueueName = "operations"
)

type SendMessageResult

type SendMessageResult struct {
	Success bool
	Error   error
}

type ServiceBusMessageHandler

type ServiceBusMessageHandler interface {
	Handle(ctx context.Context, message *azservicebus.ReceivedMessage) error
}

func NewServiceMessageHandler

func NewServiceMessageHandler(handler any) (ServiceBusMessageHandler, error)

Creates a new service bus message handler from any handler struct by wrapping it required implementation of the handler: { Handle(message *T, context MessageHandlerContext) error }

type ServiceBusMessageReceiverOptions

type ServiceBusMessageReceiverOptions struct {
	MessageReceiverOptions
	FullyQualifiedNamespace string
	MaxMessages             int
}