mqtt

Documentation

Index

• Variables
• func Close()
• func Open(cfg Options) error
• func OpenBy(fn paho.OpenConnectionFunc) error
• func Publish(topic string, payload []byte, retain bool, qos byte) error
• func PublishJson(topic string, payload any) error
• type Options
  • func Default() Options

Variables

var Client paho.Client

Functions

func Close

func Close()

func Open

func Open(cfg Options) error

func OpenBy

func OpenBy(fn paho.OpenConnectionFunc) error

func Publish

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

func PublishJson

func PublishJson(topic string, payload any) error

Types

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