mbus

package
v0.0.0-...-6b5aff9 Latest Latest
Warning

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

Go to latest
Published: Jan 18, 2019 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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,
	blobManager boshagentblobstore.BlobManagerInterface,
	logger boshlog.Logger,
	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

type TimeoutNatsClient

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

func NewTimeoutNatsClient

func NewTimeoutNatsClient(client yagnats.NATSClient, clock clock.Clock) *TimeoutNatsClient

func (*TimeoutNatsClient) BeforeConnectCallback

func (c *TimeoutNatsClient) BeforeConnectCallback(callback func())

func (*TimeoutNatsClient) Connect

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

func (*TimeoutNatsClient) Disconnect

func (c *TimeoutNatsClient) Disconnect()

func (*TimeoutNatsClient) Ping

func (c *TimeoutNatsClient) Ping() bool

func (*TimeoutNatsClient) Publish

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

func (*TimeoutNatsClient) PublishWithReplyTo

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

func (*TimeoutNatsClient) Subscribe

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

func (*TimeoutNatsClient) SubscribeWithQueue

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

func (*TimeoutNatsClient) Unsubscribe

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

func (*TimeoutNatsClient) UnsubscribeAll

func (c *TimeoutNatsClient) UnsubscribeAll(subject string)

Directories

Path Synopsis
This file was generated by counterfeiter This file was generated by counterfeiter
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