mqtt

Documentation

Index

• type Mqtt
  • func New(ctx context.Context, brokerUrl string, clientId string, username string, ...) (client *Mqtt, err error)
  • func (this *Mqtt) Publish(topic string, qos byte, retained bool, payload []byte) error
  • func (this *Mqtt) Subscribe(topic string, qos byte, handler func(topic string, payload []byte)) error
  • func (this *Mqtt) Unsubscribe(topic string) error
• type Subscription

Types

type Mqtt

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

func New

func New(ctx context.Context, brokerUrl string, clientId string, username string, password string) (client *Mqtt, err error)

func (*Mqtt) Publish

func (this *Mqtt) Publish(topic string, qos byte, retained bool, payload []byte) error

func (*Mqtt) Subscribe

func (this *Mqtt) Subscribe(topic string, qos byte, handler func(topic string, payload []byte)) error

func (*Mqtt) Unsubscribe

func (this *Mqtt) Unsubscribe(topic string) error

type Subscription

type Subscription struct {
	Topic   string
	Handler paho.MessageHandler
}