The highest tagged major version is v4.

mqtt

package

v3.4.25 Latest Latest Go to latest Published: Dec 13, 2023 License: GPL-3.0 Imports: 7 Imported by: 31

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/zgwit/iot-master

Links

Open Source Insights

Documentation ¶

Rendered for

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 ¶

View Source

const ENV = "IOT_MASTER_MQTT_"

Variables ¶

View Source

var Client paho.Client

Functions ¶

func Close ¶

func Close()

func Load ¶ added in v3.1.0

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 ¶ added in v3.4.0

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

func SetOptions ¶ added in v3.1.0

func SetOptions(opts Options)

func Store ¶ added in v3.1.0

func Store() error

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

func SubscribeJson ¶ added in v3.4.0

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

func SubscribeStruct ¶ added in v3.4.0

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

Types ¶

type Handler ¶ added in v3.4.0

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 ¶ added in v3.1.0

func GetOptions() Options

func (*Options) FromEnv ¶ added in v3.1.0

func (options *Options) FromEnv()

func (*Options) ToEnv ¶ added in v3.1.0

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL

Documentation ¶

Index ¶

Constants ¶

Variables ¶

Functions ¶

func Close ¶

func Load ¶ added in v3.1.0

func Open ¶

func OpenBy ¶

func Publish ¶

func PublishRaw ¶ added in v3.4.0

func SetOptions ¶ added in v3.1.0

func Store ¶ added in v3.1.0

func Subscribe ¶ added in v3.4.0

func SubscribeJson ¶ added in v3.4.0

func SubscribeStruct ¶ added in v3.4.0

Types ¶

type Handler ¶ added in v3.4.0

type Options ¶

func Default ¶

func GetOptions ¶ added in v3.1.0

func (*Options) FromEnv ¶ added in v3.1.0

func (*Options) ToEnv ¶ added in v3.1.0

Source Files ¶