mbus

Documentation

Index

• type HTTPHandlerFunc
• type HTTPSDispatcher
  • func NewHTTPSDispatcher(baseURL *url.URL, keyPair settings.CertKeyPair, logger boshlog.Logger) *HTTPSDispatcher
  • func (h *HTTPSDispatcher) AddRoute(route string, handler HTTPHandlerFunc)
  • func (h *HTTPSDispatcher) Start() error
  • func (h *HTTPSDispatcher) Stop()
• type HTTPSHandler
  • func NewHTTPSHandler(parsedURL *url.URL, keyPair settings.CertKeyPair, logger boshlog.Logger, ...) HTTPSHandler
  • func (h HTTPSHandler) RegisterAdditionalFunc(handlerFunc boshhandler.Func)
  • func (h HTTPSHandler) Run(handlerFunc boshhandler.Func) error
  • func (h HTTPSHandler) Send(target boshhandler.Target, topic boshhandler.Topic, message interface{}) error
  • func (h HTTPSHandler) Start(handlerFunc boshhandler.Func) error
  • func (h HTTPSHandler) Stop()
• 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)
• type PublishTimeoutNatsClient
  • func NewPublishTimeoutNatsClient(client yagnats.NATSClient, clock clock.Clock) *PublishTimeoutNatsClient
  • func (c *PublishTimeoutNatsClient) BeforeConnectCallback(callback func())
  • func (c *PublishTimeoutNatsClient) Connect(connectionProvider yagnats.ConnectionProvider) error
  • func (c *PublishTimeoutNatsClient) Disconnect()
  • func (c *PublishTimeoutNatsClient) Ping() bool
  • func (c *PublishTimeoutNatsClient) Publish(subject string, payload []byte) error
  • func (c *PublishTimeoutNatsClient) PublishWithReplyTo(subject, reply string, payload []byte) error
  • func (c *PublishTimeoutNatsClient) Subscribe(subject string, callback yagnats.Callback) (int64, error)
  • func (c *PublishTimeoutNatsClient) SubscribeWithQueue(subject, queue string, callback yagnats.Callback) (int64, error)
  • func (c *PublishTimeoutNatsClient) Unsubscribe(subscription int64) error
  • func (c *PublishTimeoutNatsClient) UnsubscribeAll(subject string)

Types

type HTTPHandlerFunc

type HTTPHandlerFunc func(writer http.ResponseWriter, request *http.Request)

type HTTPSDispatcher

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

func NewHTTPSDispatcher

func NewHTTPSDispatcher(baseURL *url.URL, keyPair settings.CertKeyPair, logger boshlog.Logger) *HTTPSDispatcher

func (*HTTPSDispatcher) AddRoute

func (h *HTTPSDispatcher) AddRoute(route string, handler HTTPHandlerFunc)

func (*HTTPSDispatcher) Start

func (h *HTTPSDispatcher) Start() error

func (*HTTPSDispatcher) Stop

func (h *HTTPSDispatcher) Stop()

type HTTPSHandler

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

func NewHTTPSHandler

func NewHTTPSHandler(
	parsedURL *url.URL,
	keyPair settings.CertKeyPair,
	logger boshlog.Logger,
	fs boshsys.FileSystem,
	dirProvider boshdir.Provider,
	auditLogger platform.AuditLogger,
) HTTPSHandler

func (HTTPSHandler) RegisterAdditionalFunc

func (h HTTPSHandler) RegisterAdditionalFunc(handlerFunc boshhandler.Func)

func (HTTPSHandler) Run

func (h HTTPSHandler) Run(handlerFunc boshhandler.Func) error

func (HTTPSHandler) Send

func (h HTTPSHandler) Send(target boshhandler.Target, topic boshhandler.Topic, message interface{}) error

func (HTTPSHandler) Start

func (h HTTPSHandler) Start(handlerFunc boshhandler.Func) error

func (HTTPSHandler) Stop

func (h HTTPSHandler) Stop()

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,
	auditLogger boshplatform.AuditLogger,
) (p HandlerProvider)

func (HandlerProvider) Get

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

type PublishTimeoutNatsClient

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

func NewPublishTimeoutNatsClient

func NewPublishTimeoutNatsClient(client yagnats.NATSClient, clock clock.Clock) *PublishTimeoutNatsClient

func (*PublishTimeoutNatsClient) BeforeConnectCallback

func (c *PublishTimeoutNatsClient) BeforeConnectCallback(callback func())

func (*PublishTimeoutNatsClient) Connect

func (c *PublishTimeoutNatsClient) Connect(connectionProvider yagnats.ConnectionProvider) error

func (*PublishTimeoutNatsClient) Disconnect

func (c *PublishTimeoutNatsClient) Disconnect()

func (*PublishTimeoutNatsClient) Ping

func (c *PublishTimeoutNatsClient) Ping() bool

func (*PublishTimeoutNatsClient) Publish

func (c *PublishTimeoutNatsClient) Publish(subject string, payload []byte) error

func (*PublishTimeoutNatsClient) PublishWithReplyTo

func (c *PublishTimeoutNatsClient) PublishWithReplyTo(subject, reply string, payload []byte) error

func (*PublishTimeoutNatsClient) Subscribe

func (c *PublishTimeoutNatsClient) Subscribe(subject string, callback yagnats.Callback) (int64, error)

func (*PublishTimeoutNatsClient) SubscribeWithQueue

func (c *PublishTimeoutNatsClient) SubscribeWithQueue(subject, queue string, callback yagnats.Callback) (int64, error)

func (*PublishTimeoutNatsClient) Unsubscribe

func (c *PublishTimeoutNatsClient) Unsubscribe(subscription int64) error

func (*PublishTimeoutNatsClient) UnsubscribeAll

func (c *PublishTimeoutNatsClient) UnsubscribeAll(subject string)