iot

Documentation

Index

• type IoT
  • func New(brokerAddr string, username string, password string, clientID string, ...) *IoT
  • func (iot *IoT) Connect() (mqtt.Token, error)
  • func (iot *IoT) Publish(topic string, qos byte, retained bool, payload interface{}) error
  • func (iot *IoT) Subscribe(topic string, qos byte, callback mqtt.MessageHandler) error

Types

type IoT

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

func New

func New(brokerAddr string, username string, password string, clientID string, cleanSession bool) *IoT

func (*IoT) Connect

func (iot *IoT) Connect() (mqtt.Token, error)

func (*IoT) Publish

func (iot *IoT) Publish(topic string, qos byte, retained bool, payload interface{}) error

func (*IoT) Subscribe

func (iot *IoT) Subscribe(topic string, qos byte, callback mqtt.MessageHandler) error