mqtt

package
v0.3.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 1, 2022 License: MIT Imports: 1 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ConnectedCallback 

type ConnectedCallback func(session Session)

type ConnectionLostCallback 

type ConnectionLostCallback func(session Session, reason error)

type MessageCallback 

type MessageCallback func(session Session, topic string, msg []byte)

type Payload 

type Payload struct {
	Topic   string
	Qos     uint8
	Payload []byte
}

type Session 

type Session struct {
	OnMessage     MessageCallback
	OnConnected   ConnectedCallback
	OnLostConnect ConnectionLostCallback
	ErrorMessage  string
	// contains filtered or unexported fields
}

func CreateSession 

func CreateSession(clean bool, clientId string, brokers ...string) *Session

func (*Session) AddBroker 

func (session *Session) AddBroker(broker string) *Session

func (*Session) CleanSession 

func (session *Session) CleanSession(clean bool) *Session

func (*Session) Close 

func (session *Session) Close()

func (*Session) Connect 

func (session *Session) Connect()

func (*Session) ConnectAndWait 

func (session *Session) ConnectAndWait() (err error)

func (*Session) DefaultMessageHandler 

func (session *Session) DefaultMessageHandler(_ delegate.Client, msg delegate.Message)

func (*Session) Publish 

func (session *Session) Publish(topic string, qos uint8, retained bool, payload interface{}) (err error)

func (*Session) SetAuth 

func (session *Session) SetAuth(userName string, password string) *Session

func (*Session) SetWill added in v0.0.5 

func (session *Session) SetWill(qos byte, retained bool, topic string, onLineMessage []byte, offlineMessage []byte)

func (*Session) SimplePublish added in v0.0.5 

func (session *Session) SimplePublish(topic string, payload interface{}) (err error)

func (*Session) Subscribe 

func (session *Session) Subscribe(topic string, qos uint8, callback MessageCallback) bool

func (*Session) Unsubscribe 

func (session *Session) Unsubscribe(topic string) bool

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.