mqtt-go

Yet another Go MQTT 3.1.1 client library

Go-ish interface

Fully context controlled and mockable interface.
Extensible

Easy to implement a wrapper with unified interface. e.g. AWS IoT WebSocket dialer with automatic presign URL updater is available: AWS IoT Device SDK for Go
Thread-safe

All functions and structs are safe to be used from multiple goroutines.

Migration guide

Examples

Reference

MQTT Version 3.1.1 Plus Errata 01

License

This package is licensed under Apache License Version 2.0.

Name		Name	Last commit message	Last commit date
Latest commit History 253 Commits
.github		.github
examples		examples
integration		integration
internal/filteredpipe		internal/filteredpipe
mock		mock
paho		paho
LICENSE		LICENSE
MIGRATION.md		MIGRATION.md
README.md		README.md
atomic.go		atomic.go
atomic_test.go		atomic_test.go
client.go		client.go
client_integration_test.go		client_integration_test.go
client_test.go		client_test.go
codecov.yml		codecov.yml
conn.go		conn.go
conn_integration_test.go		conn_integration_test.go
connack.go		connack.go
connect.go		connect.go
connect_test.go		connect_test.go
dialer.go		dialer.go
dialer_integration_test.go		dialer_integration_test.go
dialer_test.go		dialer_test.go
disconnect.go		disconnect.go
docker-compose.yml		docker-compose.yml
error.go		error.go
error_test.go		error_test.go
filter.go		filter.go
filter_test.go		filter_test.go
go.mod		go.mod
go.sum		go.sum
keepalive.go		keepalive.go
keepalive_integration_test.go		keepalive_integration_test.go
message.go		message.go
mqtt.go		mqtt.go
mqtt_test.go		mqtt_test.go
packet.go		packet.go
packet_bench_test.go		packet_bench_test.go
packet_test.go		packet_test.go
pingreq.go		pingreq.go
pingresp.go		pingresp.go
puback.go		puback.go
pubcomp.go		pubcomp.go
publish.go		publish.go
publish_test.go		publish_test.go
pubrec.go		pubrec.go
pubrel.go		pubrel.go
reconnclient.go		reconnclient.go
reconnclient_integration_test.go		reconnclient_integration_test.go
reconnclient_test.go		reconnclient_test.go
retryclient.go		retryclient.go
retryclient_integration_test.go		retryclient_integration_test.go
retryclient_test.go		retryclient_test.go
serve.go		serve.go
serve_bench_test.go		serve_bench_test.go
serve_test.go		serve_test.go
serveasync.go		serveasync.go
serveasync_test.go		serveasync_test.go
servemux.go		servemux.go
servemux_test.go		servemux_test.go
suback.go		suback.go
subscribe.go		subscribe.go
subscriptions.go		subscriptions.go
subscriptions_test.go		subscriptions_test.go
uniqid.go		uniqid.go
uniqid_test.go		uniqid_test.go
unsuback.go		unsuback.go
unsubscribe.go		unsubscribe.go

License

at-wat/mqtt-go

Folders and files

Latest commit

History

Repository files navigation

mqtt-go

Yet another Go MQTT 3.1.1 client library

Migration guide