mqtt

Documentation

Index

• func NewClient() (mqtt.Client, error)
• type Connection
  • func NewConnection() *Connection
  • func (c *Connection) StartSender()
  • func (c *Connection) StartStatusReceiver()

Functions

func NewClient

func NewClient() (mqtt.Client, error)

Types

type Connection

type Connection struct {
	Client          mqtt.Client
	ResourceChannel chan db.ResourceMessage
}

func NewConnection

func NewConnection() *Connection

func (*Connection) StartSender

func (c *Connection) StartSender()

func (*Connection) StartStatusReceiver

func (c *Connection) StartStatusReceiver()