mbus

package
v2.8.2+incompatible Latest Latest
Warning

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

Go to latest
Published: Aug 17, 2017 License: Apache-2.0 Imports: 29 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)

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)

Directories

Path Synopsis
This file was generated by counterfeiter
This file was generated by counterfeiter

Jump to

Keyboard shortcuts

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