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 = message.QosExactlyOnce + func NewMemProvider() *memTopics + func Register(name string, provider TopicsProvider) + func TopicInit(topicPro string) + func Unregister(name string) + type Manager struct + func NewManager(providerName string) (*Manager, error) + func (this *Manager) AllSubInfo() (map[string][]string, error) + func (this *Manager) Close() error + func (this *Manager) Retain(msg *message.PublishMessage) error + func (this *Manager) Retained(topic []byte, msgs *[]*message.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, svc bool, ...) error + func (this *Manager) Unsubscribe(topic []byte, subscriber interface{}) error + type TopicsProvider interface + AllSubInfo func() (map[string][]string, error) + Close func() error + Retain func(msg *message.PublishMessage) error + Retained func(topic []byte, msgs *[]*message.PublishMessage) error + Subscribe func(topic []byte, qos byte, subscriber interface{}) (byte, error) + Subscribers func(topic []byte, qos byte, subs *[]interface{}, qoss *[]byte, svc bool, ...) error + Unsubscribe func(topic []byte, subscriber interface{}) error v0.0.2-temp Aug 19, 2021
Go to main page