mqtt

Documentation

Index

• type Client
  • func NewClient(config *config.Config) *Client
  • func (c *Client) Disconnect()
  • func (c *Client) Publish(topic string, qos byte, retained bool, message string)
  • func (c *Client) PublishMessage(topic string, title string, message string)
  • func (c *Client) Subscribe(topic string, qos byte)
  • func (c *Client) WaitForMessages()
• type MessagePayload
• type MqttMessage

Types

type Client

type Client struct {
	Messages chan MqttMessage
	// contains filtered or unexported fields
}

func NewClient

func NewClient(config *config.Config) *Client

func (*Client) Disconnect

func (c *Client) Disconnect()

func (*Client) Publish

func (c *Client) Publish(topic string, qos byte, retained bool, message string)

func (*Client) PublishMessage

func (c *Client) PublishMessage(topic string, title string, message string)

func (*Client) Subscribe

func (c *Client) Subscribe(topic string, qos byte)

func (*Client) WaitForMessages

func (c *Client) WaitForMessages()

type MessagePayload

type MessagePayload struct {
	Title    string `json:"title"`
	Body     string `json:"body"`
	Topic    string `json:"topic"`
	SentFrom string `json:"sentFrom"`
}

type MqttMessage

type MqttMessage struct {
	Topic   string
	Message string
}