Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Unsubscribe ¶
func UnsubscribeAll ¶
func UnsubscribeAll(sessionId string)
Types ¶
type MessageHandler ¶
type MessageHandler struct {
// contains filtered or unexported fields
}
func NewMessageHandler ¶
func NewMessageHandler(client *client.Client) *MessageHandler
func (*MessageHandler) HandleMessage ¶
func (handler *MessageHandler) HandleMessage() error
type MqttServer ¶
type MqttServer struct {
// contains filtered or unexported fields
}
func NewMqttServer ¶
func NewMqttServer(config *config.ServerConfig) *MqttServer
func (*MqttServer) SetAuthProvider ¶ added in v0.3.0
func (server *MqttServer) SetAuthProvider(authProvider security.AuthenticationProvider)
Click to show internal directories.
Click to hide internal directories.