Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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

mqtt

package

Go to main page

Versions in this module

v0

v0.9.1

May 2, 2023

Changes in this version

+ var ErrNotImplemented = errors.New("not implemented")

type ModuleTransport

+ func (tr *ModuleTransport) SubscribeTwinUpdates(ctx context.Context, mux transport.TwinStateDispatcher) error

type Transport

+ func (tr *Transport) CreateModule(ctx context.Context, m *iotservice.Module) (*iotservice.Module, error)

+ func (tr *Transport) DeleteModule(ctx context.Context, m *iotservice.Module) error

+ func (tr *Transport) GetModule(ctx context.Context, moduleID string) (*iotservice.Module, error)

+ func (tr *Transport) ListModules(ctx context.Context) ([]*iotservice.Module, error)

+ func (tr *Transport) UpdateModule(ctx context.Context, m *iotservice.Module) (*iotservice.Module, error)

v0.9.0

Dec 14, 2021

Changes in this version

type Transport

+ func (tr *Transport) GetBlobSharedAccessSignature(ctx context.Context, blobName string) (string, string, error)

+ func (tr *Transport) NotifyUploadComplete(ctx context.Context, correlationID string, success bool, statusCode int, ...) error

+ func (tr *Transport) UploadToBlob(ctx context.Context, sasURI string, file io.Reader, size int64) error

v0.8.0

Oct 21, 2021

v0.7.0

Feb 25, 2021

v0.6.2

Jan 16, 2021

Changes in this version

type TransportOption

+ func WithModelID(modelID string) TransportOption

v0.6.1

Nov 9, 2020

Changes in this version

+ func NewModuleTransport(opts ...TransportOption) transport.Transport

+ type ModuleTransport struct

+ func (tr *ModuleTransport) Connect(ctx context.Context, creds transport.Credentials) error

+ func (tr *ModuleTransport) Send(ctx context.Context, msg *common.Message) error

+ func (tr *ModuleTransport) SubscribeEvents(ctx context.Context, mux transport.MessageDispatcher) error

v0.6.0

Jan 22, 2020

Changes in this version

type TransportOption

+ func WithWebSocket(enable bool) TransportOption

v0.5.0

Jan 12, 2020

v0.4.0

Oct 5, 2019

v0.3.0

Jun 18, 2019

v0.2.0

Jun 9, 2019

v0.1.0

Apr 24, 2019

Changes in this version

type Transport

+ func (tr *Transport) SetLogger(logger common.Logger)

v0.0.1

Apr 8, 2019

Changes in this version

+ const DefaultQoS

+ func New(opts ...TransportOption) transport.Transport

+ type Transport struct

+ func (tr *Transport) Close() error

+ func (tr *Transport) Connect(ctx context.Context, creds transport.Credentials) error

+ func (tr *Transport) RegisterDirectMethods(ctx context.Context, mux transport.MethodDispatcher) error

+ func (tr *Transport) RetrieveTwinProperties(ctx context.Context) ([]byte, error)

+ func (tr *Transport) Send(ctx context.Context, msg *common.Message) error

+ func (tr *Transport) SubscribeEvents(ctx context.Context, mux transport.MessageDispatcher) error

+ func (tr *Transport) SubscribeTwinUpdates(ctx context.Context, mux transport.TwinStateDispatcher) error

+ func (tr *Transport) UpdateTwinProperties(ctx context.Context, b []byte) (int, error)

+ type TransportOption func(tr *Transport)

+ func WithClientOptionsConfig(fn func(opts *mqtt.ClientOptions)) TransportOption

+ func WithLogger(l common.Logger) TransportOption