mbus

type ConnectionInfo struct {
	Addr      string
	IP        string
	IPs       []string
	Dial      func(network, address string) (net.Conn, error)
	TLSConfig *tls.Config
}

type ConnectionTLSInfo struct {
	CertPool              *x509.CertPool
	ClientCert            *tls.Certificate
	VerifyPeerCertificate func(rawCerts [][]byte, verifiedChains [][]*x509.Certificate) error
}

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

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

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

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()
}

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

type NatsConnection interface {
	Close()
	Publish(subj string, data []byte) error
	Subscribe(subj string, cb nats.MsgHandler) (*nats.Subscription, error)
}

type NatsConnector func(url string, options ...nats.Option) (NatsConnection, error)