mqtt

Documentation

Index

• Constants
• Variables
• func Publish(topic string, payload any) paho.Token
• func Shutdown() error
• func Startup() error
• 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 Publish

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

func Shutdown

func Shutdown() error

func Startup

func Startup() error

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