mqtt

Documentation

Index

• 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
• func WithAutoReconnect(enable bool) broker.Option
• func WithCleanSession(enable bool) broker.Option
• func WithClientId(clientId string) broker.Option
• func WithOrderMatters(enable bool) broker.Option
• func WithPublishQos(qos byte) broker.PublishOption
• func WithPublishRetained(qos byte) broker.PublishOption
• func WithResumeSubs(enable bool) broker.Option
• func WithSubscribeQos(qos byte) broker.SubscribeOption
• type AuthRecord

Functions

func FindHeader

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

func NewBroker

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

func NewCache

func NewCache(timeout time.Duration) *cache

初始化缓存

func WithAuth

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

WithAuth set username & password options

func WithAutoReconnect

func WithAutoReconnect(enable bool) broker.Option

WithAutoReconnect enable aut reconnect option

func WithCleanSession

func WithCleanSession(enable bool) broker.Option

WithCleanSession enable clean session option

func WithClientId

func WithClientId(clientId string) broker.Option

WithClientId set client id option

func WithOrderMatters

func WithOrderMatters(enable bool) broker.Option

WithOrderMatters .

func WithPublishQos

func WithPublishQos(qos byte) broker.PublishOption

WithPublishQos QOS

func WithPublishRetained

func WithPublishRetained(qos byte) broker.PublishOption

WithPublishRetained retained

func WithResumeSubs

func WithResumeSubs(enable bool) broker.Option

WithResumeSubs .

func WithSubscribeQos

func WithSubscribeQos(qos byte) broker.SubscribeOption

WithSubscribeQos QOS

Types

type AuthRecord

type AuthRecord struct {
	Username string
	Password string
}