servicebus

package
v0.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 4, 2018 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL