mqtt

Documentation

Index

• Constants
• Variables
• func Close()
• func Load() error
• func Open() 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
• func SetOptions(opts Options)
• func Store() error
• 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 []byte, retain bool, qos byte) error

func PublishJson

func PublishJson(topic string, payload any) error

func SetOptions

func SetOptions(opts Options)

func Store

func Store() 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

func GetOptions

func GetOptions() Options

func (*Options) FromEnv

func (options *Options) FromEnv()

func (*Options) ToEnv

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