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 ShareTopicsProvider) + func ShareTopicInit() + 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, shareName []byte) error + func (this *Manager) Retained(topic, shareName []byte, msgs *[]*message.PublishMessage) error + func (this *Manager) Subscribe(topic, shareName []byte, qos byte, subscriber interface{}) (byte, error) + func (this *Manager) Subscribers(topic, shareName []byte, qos byte, subs *[]interface{}, qoss *[]byte) error + func (this *Manager) Unsubscribe(topic, shareName []byte, subscriber interface{}) error + type ShareTopicsProvider interface + AllSubInfo func() (map[string][]string, error) + Close func() error + Retain func(msg *message.PublishMessage, shareName []byte) error + Retained func(topic, shareName []byte, msgs *[]*message.PublishMessage) error + Subscribe func(topic, shareName []byte, qos byte, subscriber interface{}) (byte, error) + Subscribers func(topic, shareName []byte, qos byte, subs *[]interface{}, qoss *[]byte) error + Unsubscribe func(topic, shareName []byte, subscriber interface{}) error v0.0.2-temp Aug 19, 2021
Go to main page