mqtt

Documentation

Index

• type BrokerConfig
• type Client
  • func NewClient(broker *BrokerConfig, clientID, dataDir string, clean bool) (*Client, error)
  • func (m *Client) Close() error
  • func (m *Client) PublishUpdate(topic string, sup *pb.StateUpdatePoint) pmqtt.Token

Types

type BrokerConfig

type BrokerConfig struct {
	Hostname string `yaml:"hostname"`
	Port     uint16 `yaml:"port"`

	Username string `yaml:"username"`
	Password string `yaml:"password"`

	Topic string `yaml:"topic"`
}

type Client

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

func NewClient

func NewClient(broker *BrokerConfig, clientID, dataDir string, clean bool) (*Client, error)

func (*Client) Close

func (m *Client) Close() error

func (*Client) PublishUpdate

func (m *Client) PublishUpdate(topic string, sup *pb.StateUpdatePoint) pmqtt.Token