mqtt

Documentation

Index

• func NewBroker(opts ...broker.Option) broker.Broker
• 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 WithCriticalLogger() broker.Option
• func WithDebugLogger() broker.Option
• func WithErrorLogger() broker.Option
• func WithLogger(opt LoggerOptions) 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
• func WithWarnLogger() broker.Option
• type AuthRecord
• type CriticalLogger
  • func (CriticalLogger) Printf(format string, v ...interface{})
  • func (CriticalLogger) Println(v ...interface{})
• type DebugLogger
  • func (DebugLogger) Printf(format string, v ...interface{})
  • func (DebugLogger) Println(v ...interface{})
• type ErrorLogger
  • func (ErrorLogger) Printf(format string, v ...interface{})
  • func (ErrorLogger) Println(v ...interface{})
• type LoggerOptions
• type WarnLogger
  • func (WarnLogger) Printf(format string, v ...interface{})
  • func (WarnLogger) Println(v ...interface{})

Functions

func NewBroker

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

NewBroker news broker instance with options

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 WithCriticalLogger

func WithCriticalLogger() broker.Option

WithCriticalLogger .

func WithDebugLogger

func WithDebugLogger() broker.Option

WithDebugLogger .

func WithErrorLogger

func WithErrorLogger() broker.Option

WithErrorLogger .

func WithLogger

func WithLogger(opt LoggerOptions) broker.Option

WithLogger .

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

func WithWarnLogger

func WithWarnLogger() broker.Option

WithWarnLogger .

Types

type AuthRecord

type AuthRecord struct {
	Username string
	Password string
}

type CriticalLogger

type CriticalLogger struct{}

func (CriticalLogger) Printf

func (CriticalLogger) Printf(format string, v ...interface{})

Printf .

func (CriticalLogger) Println

func (CriticalLogger) Println(v ...interface{})

Println .

type DebugLogger

type DebugLogger struct{}

func (DebugLogger) Printf

func (DebugLogger) Printf(format string, v ...interface{})

Printf .

func (DebugLogger) Println

func (DebugLogger) Println(v ...interface{})

Println .

type ErrorLogger

type ErrorLogger struct{}

func (ErrorLogger) Printf

func (ErrorLogger) Printf(format string, v ...interface{})

Printf .

func (ErrorLogger) Println

func (ErrorLogger) Println(v ...interface{})

Println .

type LoggerOptions

type LoggerOptions struct {
	Error    bool
	Critical bool
	Warn     bool
	Debug    bool
}

type WarnLogger

type WarnLogger struct{}

func (WarnLogger) Printf

func (WarnLogger) Printf(format string, v ...interface{})

Printf .

func (WarnLogger) Println

func (WarnLogger) Println(v ...interface{})

Println .