mqtt

Documentation

Index

• Constants
• Variables
• func Close()
• func Open() paho.Token
• func OpenBy(fn paho.OpenConnectionFunc) paho.Token
• func Publish(topic string, payload any) paho.Token
• func Subscribe(filter string, cb func(topic string, payload []byte)) paho.Token
• func SubscribeExt[T any](filter string, cb func(topic string, value *T))
• func SubscribeStruct[T any](filter string, cb func(topic string, data *T)) paho.Token

Constants

const MODULE = "mqtt"

Variables

var Client paho.Client

Functions

func Close

func Close()

func Open

func Open() paho.Token

func OpenBy

func OpenBy(fn paho.OpenConnectionFunc) paho.Token

func Publish

func Publish(topic string, payload any) paho.Token

func Subscribe

func Subscribe(filter string, cb func(topic string, payload []byte)) paho.Token

func SubscribeExt

func SubscribeExt[T any](filter string, cb func(topic string, value *T))

func SubscribeStruct

func SubscribeStruct[T any](filter string, cb func(topic string, data *T)) paho.Token