mqtt

Dec 11, 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")

+ 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)