mbus

package
v2.10.0+incompatible Latest Latest
Warning

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

Go to latest
Published: Aug 11, 2017 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type HTTPHandlerFunc added in v0.0.33

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

type HTTPSDispatcher added in v0.0.33

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

func NewHTTPSDispatcher added in v0.0.33

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

func (*HTTPSDispatcher) AddRoute added in v0.0.33

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

func (*HTTPSDispatcher) Start added in v0.0.33

func (h *HTTPSDispatcher) Start() error

func (*HTTPSDispatcher) Stop added in v0.0.33

func (h *HTTPSDispatcher) Stop()

type HTTPSHandler added in v0.0.33

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

func NewHTTPSHandler added in v0.0.33

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

func (HTTPSHandler) RegisterAdditionalFunc added in v0.0.33

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

func (HTTPSHandler) Run added in v0.0.33

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

func (HTTPSHandler) Send added in v0.0.33

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

func (HTTPSHandler) Start added in v0.0.33

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

func (HTTPSHandler) Stop added in v0.0.33

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)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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