Versions in this module Expand all Collapse all v1 v1.0.8 Mar 12, 2023 Changes in this version + func GetClient(opts *mqtt.ClientOptions) (client mqtt.Client, err error) + func GetClientOptions(conf *Config) *mqtt.ClientOptions + func Init(opts *mqtt.ClientOptions) (err error) + func Publish(topic string, payload interface{}, qos byte, retained bool) (err error) + func Subscribe(item SubscribeType) + type Config struct + Broker string + CACert string + ClientCert string + ClientID string + ClientKey string + Password string + Username string + type SubscribeType struct + Callback mqtt.MessageHandler + Qos byte + RetryTimes int + Topic string