Documentation
¶
Index ¶
- func AddNewSubscription(clientID string, nc *nats.Conn)
- func GetSubscriptionForClient(clientID string) *nats.Subscription
- func HandleConnectionRequest(ctx *gin.Context)
- func InitSubscriptionMgr() error
- func NewCertMiddleware(persistence persistence.LocationKeyStore) *certMiddleware
- func NewCertMiddlewareDetailed(timeout time.Duration, persistence persistence.LocationKeyStore) *certMiddleware
- func RunBridgeServer(test bool)
- func RunBridgeServerApp(test bool)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddNewSubscription ¶
func AddNewSubscription(clientID string, nc *nats.Conn)
func GetSubscriptionForClient ¶
func GetSubscriptionForClient(clientID string) *nats.Subscription
gets the subscription for the client ID or returns nil
func HandleConnectionRequest ¶
func InitSubscriptionMgr ¶
func InitSubscriptionMgr() error
func NewCertMiddleware ¶
func NewCertMiddleware(persistence persistence.LocationKeyStore) *certMiddleware
func NewCertMiddlewareDetailed ¶
func NewCertMiddlewareDetailed(timeout time.Duration, persistence persistence.LocationKeyStore) *certMiddleware
func RunBridgeServerApp ¶
func RunBridgeServerApp(test bool)
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.