Versions in this module Expand all Collapse all v0 v0.14.0 Jan 29, 2024 Changes in this version + var ErrConnect = errors.New("failed to connect to MQTT broker") + var ErrEmptyID = errors.New("empty ID") + var ErrEmptyTopic = errors.New("empty topic") + var ErrNotSubscribed = errors.New("not subscribed") + var ErrSubscribeTimeout = errors.New("failed to subscribe due to timeout reached") + var ErrUnsubscribeDeleteTopic = errors.New("failed to unsubscribe due to deletion of topic") + var ErrUnsubscribeTimeout = errors.New("failed to unsubscribe due to timeout reached") + func NewPubSub(url string, qos uint8, timeout time.Duration, logger *slog.Logger) (messaging.PubSub, error) + func NewPublisher(address string, qos uint8, timeout time.Duration) (messaging.Publisher, error)