mqtt

Documentation

Index

• Constants
• type Client
  • func NewMQTTClient() (*Client, error)
  • func (c *Client) Publish(msgs ...*Msg) error
  • func (c *Client) Subscribe(subs ...*Subscription) error
• type Msg
• type Subscription

Constants

const (
	DiscoveryPrefix = "homeassistant"
	DefaultServer   = "localhost:1883"
)

Types

type Client

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

func NewMQTTClient

func NewMQTTClient() (*Client, error)

func (*Client) Publish

func (c *Client) Publish(msgs ...*Msg) error

func (*Client) Subscribe

func (c *Client) Subscribe(subs ...*Subscription) error

type Msg

type Msg struct {
	Topic    string
	Message  json.RawMessage
	QOS      byte
	Retained bool
}

type Subscription

type Subscription struct {
	Callback func(MQTT.Client, MQTT.Message)
	Topic    string
	QOS      byte
	Retained bool
}