mqtt

Documentation

Index

• func Distribute(topic *string, qos int, retained bool, payload *[]byte) error
• func DistributeObject(topic *string, qos int, retained bool, obj interface{}) error
• func Init(c *Config)
• func New() (MQTT.Client, error)
• func Options() *MQTT.ClientOptions
• func Subscribe(connHandler MQTT.OnConnectHandler, lostHandler MQTT.ConnectionLostHandler) error
• func UnSubscribe(topic string)
• type Config

Functions

func Distribute

func Distribute(topic *string, qos int, retained bool, payload *[]byte) error

分发

func DistributeObject

func DistributeObject(topic *string, qos int, retained bool, obj interface{}) error

分发Object

func Init

func Init(c *Config)

func New

func New() (MQTT.Client, error)

func Options

func Options() *MQTT.ClientOptions

func Subscribe

func Subscribe(connHandler MQTT.OnConnectHandler, lostHandler MQTT.ConnectionLostHandler) error

订阅，当事件为nil时可获取client

func UnSubscribe

func UnSubscribe(topic string)

取消订阅

Types

type Config

type Config struct {
	Host     string
	Username string
	Password string
	ClientID string
}