client

Jan 18, 2021

Changes in this version

+ func MqttPayloadToBytes(payload interface{}) ([]byte, error)

+ func NewErrorToken(err error) mqtt.Token

+ func NewNamespaceClientOptions(clientId string) *mqtt.ClientOptions

+ func SetFactory(fac Factory)

+ type Factory func(options config.MqttClientConfig, onConnect func(mqtt.Client)) (mqtt.Client, error)

+ var ClientFactory Factory

+ type PublishingConfig struct

+ func NewTopicConfig(topic string) PublishingConfig

+ func (a *PublishingConfig) Publish(target mqtt.Client, payload interface{}) mqtt.Token

+ func (a *PublishingConfig) RetainFlag() bool

+ func (a *PublishingConfig) WithRetainFlag(retain bool)

+ type QoS byte

+ const AtLeastOnce

+ const AtMostOnce

+ const ExactlyOnce

+ type Subscription interface

+ PayloadFactory func() interface{}

+ SubscriptionHandler func(payload interface{}, err error)

+ type SubscriptionConfig struct

+ func (a *SubscriptionConfig) QualityOfService() QoS

+ func (a *SubscriptionConfig) Subscribe(target mqtt.Client, subscription Subscription) mqtt.Token

+ func (a *SubscriptionConfig) Topic() string

+ func (a *SubscriptionConfig) WithQualityOfService(qos QoS)