servicebus

Documentation

Index

• type Config
• type ServiceBus
  • func NewServiceBus(config *Config) (*ServiceBus, error)
  • func (s *ServiceBus) Close()
  • func (s *ServiceBus) Publish(e common.Event) error

Types

type Config

type Config struct {
	Enabled               bool   `description:"Enable Service Bus event provider"`
	Namespace             string `description:"ServiceBus namespace"`
	Topic                 string `description:"ServiceBus topic name"`
	Key                   string `description:"ServiceBus access key"`
	AuthorizationRuleName string `description:"ServiceBus authorization rule name"`
}

Config to setup a ServiceBus event publisher

type ServiceBus

type ServiceBus struct {
	URL string
	Key string
	SKN string
}

ServiceBus handles the connection to an external Service Bus

func NewServiceBus

func NewServiceBus(config *Config) (*ServiceBus, error)

NewServiceBus creates a new Service Bus object

func (*ServiceBus) Close

func (s *ServiceBus) Close()

Close cleans up any outstanding connections to Service Bus

func (*ServiceBus) Publish

func (s *ServiceBus) Publish(e common.Event) error

Publish publishes an event onto a Service Bus topic