mqtt

package module

v0.0.0-...-c396fa1 Latest Latest Go to latest Published: Mar 23, 2024 License: MIT Imports: 13 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func FindHeader(pd []byte) (n int)

func NewBroker(opts ...broker.Option) broker.Broker

func NewCache(timeout time.Duration) *cache

初始化缓存

func WithAuth(username string, password string) broker.Option

WithAuth set username & password options

func WithAutoReconnect(enable bool) broker.Option

WithAutoReconnect enable aut reconnect option

func WithCleanSession(enable bool) broker.Option

WithCleanSession enable clean session option

func WithClientId(clientId string) broker.Option

WithClientId set client id option

func WithOrderMatters(enable bool) broker.Option

WithOrderMatters .

func WithPublishQos(qos byte) broker.PublishOption

WithPublishQos QOS

func WithPublishRetained(qos byte) broker.PublishOption

WithPublishRetained retained

func WithResumeSubs(enable bool) broker.Option

WithResumeSubs .

func WithSubscribeQos(qos byte) broker.SubscribeOption

WithSubscribeQos QOS

type AuthRecord struct {
	Username string
	Password string
}