mqtt

May 9, 2025

Changes in this version

+ var ConnectionFailureError = NewError("connection failure")

+ var EmptyTopicError = NewError("subscribe topic cannot be an empty string")

+ var InvalidQoSError = NewError("qos must be one of: byte(0), byte(1), or byte(2)")

+ var NillHandlerError = NewError("subscribe handler cannot be nil")

+ var NillPayloadError = NewError("publish payload cannot be nil")

+ func LogMessage(msg ...string) string

+ func NewError(msg string) error

+ func NewPublisher(configs *configs.Configs, client myQTT.Client) messaging.Publisher

+ func ValidateQoS(qos QoS) bool

+ type Dispatcher interface

+ ConsumeBlocking func()

+ Register func(topic string, qos QoS, handler Handler) error

+ func NewDispatcher(logger logging.Logger, client myQTT.Client) Dispatcher

+ type Error struct

+ func (e *Error) Error() string

+ type Handler = func(ctx context.Context, topic string, qos QoS, payload []byte) error

+ type MQTTClient interface

+ Client func() myQTT.Client

+ Connect func() error

+ func NewMQTTClient(cfgs *configs.Configs) MQTTClient

+ type QoS byte

+ const AtLeastOnce

+ const AtMostOnce

+ const ExactlyOnce

+ func QoSFromBytes(qos byte) QoS