mqtt

Documentation

Index

• type Client
  • func NewClient(uri *url.URL, client_id string, prefix string) (*Client, error)
  • func (client *Client) PublishJSON(topic string, val interface{}) error
  • func (client *Client) PublishMany(topic string, values map[string]interface{}) error
  • func (client *Client) PublishRaw(topic string, val interface{}) error
  • func (client *Client) Subscribe(topic string, qos byte, callback MessageHandler) error
• type Message
• type MessageHandler

Types

type Client

type Client struct {
	URI      *url.URL
	ClientID string
	Prefix   string
	// contains filtered or unexported fields
}

func NewClient

func NewClient(uri *url.URL, client_id string, prefix string) (*Client, error)

func (*Client) PublishJSON

func (client *Client) PublishJSON(topic string, val interface{}) error

func (*Client) PublishMany

func (client *Client) PublishMany(topic string, values map[string]interface{}) error

func (*Client) PublishRaw

func (client *Client) PublishRaw(topic string, val interface{}) error

func (*Client) Subscribe

func (client *Client) Subscribe(topic string, qos byte, callback MessageHandler) error

type Message

type Message mqtt.Message

type MessageHandler

type MessageHandler func(client *Client, message Message)