client

Dec 19, 2023

Changes in this version

+ func CreateTLSConfig(ClientCertificatePath string, PrivateKeyPath string, ...) (tlsConfig *tls.Config, err error)

+ type Client struct

+ HubId string

+ func New(mqttUrl string, userName string, password string, hubId string, ...) (client *Client, err error)

+ func (this *Client) Publish(topic string, msg interface{}, qos byte) (err error)

+ func (this *Client) PublishMqtt4(topic string, payload []byte, qos byte) (err error)

+ func (this *Client) PublishMqtt5(topic string, payload []byte, qos byte) (err error)

+ func (this *Client) PublishRaw(topic string, payload []byte, qos byte) (err error)

+ func (this *Client) Stop()

+ func (this *Client) Subscribe(topic string, qos byte, callback func(topic string, pl []byte)) error

+ func (this *Client) SubscribeMqtt4(topic string, qos byte, callback func(topic string, pl []byte)) error

+ func (this *Client) SubscribeMqtt5(topic string, qos byte, callback func(topic string, pl []byte)) error

+ func (this *Client) Unsubscribe(topic ...string) error

+ func (this *Client) UnsubscribeMqtt4(topic ...string) (err error)

+ func (this *Client) UnsubscribeMqtt5(topic ...string) (err error)

+ type MqttVersion int

+ const MQTT4

+ const MQTT5

+ type Subscription struct

+ Handler paho.MessageHandler

+ Qos byte

+ Topic string