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

topics

package

Go to main page

Versions in this module

v1

v1.5.3

Apr 24, 2024

v1.5.2

Apr 23, 2024

v1.5.1

Oct 7, 2023

Changes in this version

+ const MWC

+ const QosAtLeastOnce

+ const QosAtMostOnce

+ const QosExactlyOnce

+ const QosFailure

+ const SEP

+ const SWC

+ const SYS

+ func NewMemProvider() *memTopics

+ func Register(name string, provider TopicsProvider)

+ func Unregister(name string)

+ func ValidQos(qos byte) bool

+ type Manager struct

+ func NewManager(providerName string) (*Manager, error)

+ func (this *Manager) Close() error

+ func (this *Manager) Retain(msg *packets.PublishPacket) error

+ func (this *Manager) Retained(topic []byte, msgs *[]*packets.PublishPacket) error

+ func (this *Manager) Subscribe(topic []byte, qos byte, subscriber interface{}) (byte, error)

+ func (this *Manager) Subscribers(topic []byte, qos byte, subs *[]interface{}, qoss *[]byte) error

+ func (this *Manager) Unsubscribe(topic []byte, subscriber interface{}) error

+ type TopicsProvider interface

+ Close func() error

+ Retain func(msg *packets.PublishPacket) error

+ Retained func(topic []byte, msgs *[]*packets.PublishPacket) error

+ Subscribe func(topic []byte, qos byte, subscriber interface{}) (byte, error)

+ Subscribers func(topic []byte, qos byte, subs *[]interface{}, qoss *[]byte) error

+ Unsubscribe func(topic []byte, subscriber interface{}) error