Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewBroker ¶
func NewBroker(router *auramq.Router, addr string, auth bool, authFunc func(*msg.AuthReq) bool, subscriberBufferSize, readBufferSize, writeBufferSize, pingWait, readWait, writeWait int) auramq.Broker
NewBroker create new websocket broker
func NewWsSubscriber ¶
func NewWsSubscriber(router *auramq.Router, conn *websocket.Conn, subscriberBufferSize, pingWait, readWait, writeWait int) auramq.Subscriber
NewWsSubscriber create a new websocket subscriber
Types ¶
type Broker ¶
type Broker struct {
// contains filtered or unexported fields
}
Broker websocket broker
type WsSubscriber ¶
type WsSubscriber struct {
// contains filtered or unexported fields
}
WsSubscriber subscriber for websocket broker
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.