Versions in this module Expand all Collapse all v1 v1.0.0 Nov 7, 2021 Changes in this version + type MqttConf struct + CaFile string + ClientCrt string + ClientKey string + FileStorePath string + Password string + TCP string + UserName string + func (mm *MqttConf) NewMqttServ(serviceID string, l log.Logger) (MqttServ, error) + func (mm *MqttConf) NewMqttServWithFileStore(serviceID, clientID string, l log.Logger) (MqttServ, error) + type MqttDI interface + NewMqttServ func(serviceID string, l log.Logger) (MqttServ, error) + NewMqttServWithFileStore func(serviceID, clientID string, l log.Logger) (MqttServ, error) + type MqttServ interface + Disconnect func() + Publish func(topics []string, message map[string]interface{}, retain bool) error + PublishByte func(topics []string, data []byte, retain bool) error + Subcribe func(mssm MqttSubSerInter) error + SubscribeMultiple func(mssm MqttSubSerMap) error + type MqttSubSerInter interface + GetQos func() byte + GetTopic func() string + Handler func(client mqtt.Client, msg mqtt.Message) + type MqttSubSerMap map[string]MqttSubSerInter + func (mssl MqttSubSerMap) Add(mss MqttSubSerInter) + func (mssl MqttSubSerMap) GetSubscribeMap() map[string]byte + func (mssl MqttSubSerMap) Handler(client mqtt.Client, message mqtt.Message)
Go to main page