Versions in this module Expand all Collapse all v1 v1.0.1 Mar 12, 2025 Changes in this version + var AutoTask *autoTask + func DelClient(clientId string) + func HasClient(clientId string) bool + func Keys() map[string]interface + type MqttClient struct + func GetClient(clientId string) *MqttClient + func NewClient(clientId string) *MqttClient + func (e *MqttClient) Connect() error + func (e *MqttClient) Disconnect() error + func (e *MqttClient) GetClient() mqtt.Client + func (e *MqttClient) HasTopic(topic string) bool + func (e *MqttClient) IsConnected() bool + func (e *MqttClient) Publish(topic string, payload interface{}, timeout int64) error + func (e *MqttClient) SetOption(config map[string]interface{}) error + func (e *MqttClient) Subscribe(topic string, handler mqtt.MessageHandler) error + func (e *MqttClient) Topics() []string + func (e *MqttClient) Unsubscribe(topic string) (mqtt.Token, error) + func (e *MqttClient) Unsubscribes(topics ...string) (mqtt.Token, error)
Go to main page