mqttutil

func Connect ¶

func Connect(ctx context.Context, options *mqtt.ClientOptions) (mqtt.Client, error)

func SendJSON ¶

func SendJSON(ctx context.Context, client mqtt.Client, topic string, payload any) error

SendJSON converts payload to JSON and sends on topic to client. payload will be converted to JSON using the following rules:

1. if payload is a []byte, string, or bytes.Buffer, it will be sent as-is
2. if payload is a proto.Message, it will be converted using protojson.Marshal
3. otherwise, it will be converted using json.Marshal

func WaitToken ¶

func WaitToken(ctx context.Context, token mqtt.Token) (completed bool, err error)