mqtt

Documentation

Index

• Constants
• Variables
• func Close()
• func Load() error
• func Open() error
• func OpenBy(fn paho.OpenConnectionFunc) error
• func Publish(topic string, payload any) paho.Token
• func PublishRaw(topic string, payload []byte, retain bool, qos byte) error
• func SetOptions(opts Options)
• func Store() error
• func Subscribe(topic string, cb Handler) paho.Token
• func SubscribeJson(topic string, cb func(topic string, data map[string]any)) paho.Token
• func SubscribeStruct[T any](topic string, cb func(topic string, data *T)) paho.Token
• type Handler
• type Options
  • func Default() Options
  • func GetOptions() Options
  • func (options *Options) FromEnv()
  • func (options *Options) ToEnv() []string

Constants

const ENV = "IOT_MASTER_MQTT_"

Variables

var Client paho.Client

Functions

func Close

func Close()

func Load

func Load() error

func Open

func Open() error

func OpenBy

func OpenBy(fn paho.OpenConnectionFunc) error

func Publish

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

func PublishRaw

func PublishRaw(topic string, payload []byte, retain bool, qos byte) error

func SetOptions

func SetOptions(opts Options)

func Store

func Store() error

func Subscribe

func Subscribe(topic string, cb Handler) paho.Token

func SubscribeJson

func SubscribeJson(topic string, cb func(topic string, data map[string]any)) paho.Token

func SubscribeStruct

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

Types

type Handler

type Handler func(topic string, payload []byte)

type Options

type Options struct {
	Url      string `json:"url,omitempty"`
	ClientId string `json:"clientId,omitempty"`
	Username string `json:"username,omitempty"`
	Password string `json:"password,omitempty"`
}

func Default

func Default() Options

func GetOptions

func GetOptions() Options

func (*Options) FromEnv

func (options *Options) FromEnv()

func (*Options) ToEnv

func (options *Options) ToEnv() []string