mbus

Documentation

Index

• type Handler
  • func NewNatsHandler(settingsService boshsettings.Service, client yagnats.NATSClient, ...) Handler
• type HandlerProvider
  • func NewHandlerProvider(settingsService boshsettings.Service, logger boshlog.Logger) (p HandlerProvider)
  • func (p HandlerProvider) Get(platform boshplatform.Platform, dirProvider boshdir.Provider) (handler boshhandler.Handler, err error)

Types

type Handler

type Handler interface {
	Run(boshhandler.Func) error
	Start(boshhandler.Func) error
	RegisterAdditionalFunc(boshhandler.Func)
	Send(target boshhandler.Target, topic boshhandler.Topic, message interface{}) error
	Stop()
}

func NewNatsHandler

func NewNatsHandler(
	settingsService boshsettings.Service,
	client yagnats.NATSClient,
	logger boshlog.Logger,
	platform boshplatform.Platform,
) Handler

type HandlerProvider

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

func NewHandlerProvider

func NewHandlerProvider(
	settingsService boshsettings.Service,
	logger boshlog.Logger,
) (p HandlerProvider)

func (HandlerProvider) Get

func (p HandlerProvider) Get(
	platform boshplatform.Platform,
	dirProvider boshdir.Provider,
) (handler boshhandler.Handler, err error)