azservicebus

Documentation

Overview

Package azservicebus provides a notifier that subscribes to an Service Bus topic that watches change of configuration on Azure.

It requires following roles:

• Azure Service Bus Data Owner
• Azure Service Bus Data Receiver

Index

• type Notifier
  • func NewNotifier(namespace, topic string, opts ...Option) *Notifier
  • func (n *Notifier) Register(loaders ...loader)
  • func (n *Notifier) Start(ctx context.Context) error
• type Option
  • func WithCredential(credential azcore.TokenCredential) Option
  • func WithLogHandler(handler slog.Handler) Option

Types

type Notifier

type Notifier struct {
	// contains filtered or unexported fields
}

Notifier that watches change events on given Service Bus topic.

To create a new Notifier, call NewNotifier.

func NewNotifier

func NewNotifier(namespace, topic string, opts ...Option) *Notifier

NewNotifier creates a Notifier with the given Service Bus namespace and topic.

func (*Notifier) Register

func (n *Notifier) Register(loaders ...loader)

Register registers a loader to the Notifier.

func (*Notifier) Start

func (n *Notifier) Start(ctx context.Context) error

Start starts watching events on given Service Bus topic and fanout to registered loaders. It blocks until ctx is done, or it returns an error.

type Option

type Option func(options *options)

Option configures the Notifier with specific options.

func WithCredential

func WithCredential(credential azcore.TokenCredential) Option

WithCredential provides the azcore.TokenCredential for Azure authentication.

By default, it uses azidentity.DefaultAzureCredential.

func WithLogHandler

func WithLogHandler(handler slog.Handler) Option

WithLogHandler provides the slog.Handler for logs from notifier.

By default, it uses handler from slog.Default().