Versions in this module Expand all Collapse all v1 v1.0.0 Mar 11, 2024 Changes in this version + func NewMQTTClient(opts *NewMQTTClientOptions) (*mqtt.Client, error) + func Publish(client *mqtt.Client, topic string, qos byte, payload []byte) error + func Subscribe(client *mqtt.Client, topic string, qos byte, ...) error + type NewMQTTClientOptions struct + ALPN []string + Brokers []string + ClientID string + ConnectionLostHandler func(client mqtt.Client, err error) + Password string + PasswordEncryptor PasswordEncryptor + Username string + UsernameTransformer UsernameTransformer + type PasswordEncryptor func(originalPassword string) (encryptedPassword string, err error) + func NewHmacSha1Encryptor(key string) PasswordEncryptor + type UsernameTransformer func(originalUsername string) (transformedUsername string, err error) + func NewAwsIotUsernameTransformer(customAuthName string) UsernameTransformer
Go to main page