Versions in this module Expand all Collapse all v0 v0.0.2 Sep 13, 2021 Changes in this version + const MWC + const SEP + const SWC + const SYS + var Default = "default" + var ErrAuthFailure = errors.New("auth: Authentication failure") + var ErrAuthProviderNotFound = errors.New("auth: Authentication provider not found") + var MaxQosAllowed_redis = messagev5.QosExactlyOnce + func NewMemProvider() *memTopics + func Register(name string, provider SysTopicsProvider) + func SysTopicInit() + func Unregister(name string) + type Manager struct + func NewManager(providerName string) (*Manager, error) + func (this *Manager) Close() error + func (this *Manager) Retain(msg *messagev5.PublishMessage) error + func (this *Manager) Retained(topic []byte, msgs *[]*messagev5.PublishMessage) 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 SysTopicsProvider interface + Close func() error + Retain func(msg *messagev5.PublishMessage) error + Retained func(topic []byte, msgs *[]*messagev5.PublishMessage) 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