Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

mqttgo

package

Go to main page

Versions in this module

v0

v0.0.2

Jun 26, 2025

Changes in this version

+ func NewClientWithCallback(config *Config, clientID string, callback *Callback) (mqtt.Client, error)

+ type Callback struct

+ func NewCallback() *Callback

+ func (C *Callback) OnConnect(onConnect func(client mqtt.Client, retryTimes uint64) (CallbackState, error)) *Callback

+ type CallbackState string

+ const CallbackRetries

+ const CallbackSuccess

+ const CallbackTimeout

+ const CallbackUnknown

v0.0.1

Jun 17, 2025

Changes in this version

+ func OnConnectWithRetries(c mqtt.Client, ...)

+ type TokenState string

+ const TokenStateSuccess

+ const TokenStateTimeout

+ const TokenStateUnknown

+ func CheckToken(token mqtt.Token, timeout time.Duration) (TokenState, error)

+ func WaitToken(token mqtt.Token) (TokenState, error)

v0.0.0

Jun 17, 2025

Changes in this version

+ func NewClient(cfg *Config, clientID string, ...) (mqtt.Client, error)

+ func NewClientConnect(clientOptions *mqtt.ClientOptions) (mqtt.Client, error)

+ func NewClientOptions(cfg *Config, clientID string) *mqtt.ClientOptions

+ func SetLog(mqttLog Log)

+ type Client = mqtt.Client

+ type Config struct

+ BrokerServer string

+ OrderMatters bool

+ Password string

+ Username string

+ type Log interface

+ DebugLog func(msg string, fields ...zap.Field)

+ ErrorLog func(msg string, fields ...zap.Field)

+ type Message = mqtt.Message

+ type RetryType string

+ const RetryTypeRetries

+ const RetryTypeSuccess

+ const RetryTypeTimeout

+ const RetryTypeUnknown

+ type Token = mqtt.Token