mqtt_client

Documentation

Index

• func ClientIdGen(args ...interface{}) string
• type Client
  • func NewClient(cfg *Config) (client *Client, err error)
  • func (c *Client) Connect() (err error)
  • func (c *Client) Disconnect()
  • func (c *Client) IsConnected() bool
  • func (c *Client) Publish(topic string, payload interface{}) (err error)
  • func (c *Client) Subscribe(topic string, qos byte, callback MQTT.MessageHandler) (err error)
  • func (c *Client) Unsubscribe(topic string) (err error)
• type Config
• type Subscribe

Functions

func ClientIdGen

func ClientIdGen(args ...interface{}) string

ClientIdGen ...

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

Client ...

func NewClient

func NewClient(cfg *Config) (client *Client, err error)

NewClient ...

func (*Client) Connect

func (c *Client) Connect() (err error)

Connect ...

func (*Client) Disconnect

func (c *Client) Disconnect()

Disconnect ...

func (*Client) IsConnected

func (c *Client) IsConnected() bool

IsConnected ...

func (*Client) Publish

func (c *Client) Publish(topic string, payload interface{}) (err error)

Publish ...

func (*Client) Subscribe

func (c *Client) Subscribe(topic string, qos byte, callback MQTT.MessageHandler) (err error)

Subscribe ...

func (*Client) Unsubscribe

func (c *Client) Unsubscribe(topic string) (err error)

Unsubscribe ...

type Config

type Config struct {
	KeepAlive      int
	PingTimeout    int
	Broker         string
	ClientID       string
	ConnectTimeout int
	CleanSession   bool
	Username       string
	Password       string
	Qos            byte
}

Config ...

type Subscribe

type Subscribe struct {
	Qos      byte
	Callback MQTT.MessageHandler
}

Subscribe ...