pubsub

Documentation

Index

• func Load()
• func RegisterMessageBus(name string, factoryMethod func() pubsub.PubSub)
• type Registry
  • func NewRegistry() Registry

Functions

func Load

func Load()

Load message buses

func RegisterMessageBus

func RegisterMessageBus(name string, factoryMethod func() pubsub.PubSub)

RegisterMessageBus registers a new message bus

Types

type Registry

type Registry interface {
	CreatePubSub(name string) (pubsub.PubSub, error)
}

Registry is the interface for callers to get registered pub-sub components

func NewRegistry

func NewRegistry() Registry

NewRegistry returns a new pub sub registry