Versions in this module Expand all Collapse all v0 v0.0.2 Sep 13, 2021 Changes in this version + const MQ_TAG_CLU + var Default = "default" + var ErrKeyNotAvailable = errors.New("Session: not item found for key.") + var ErrSessionsProviderNotFound = errors.New("Session: Session provider not found") + func NewMemProvider() *memProvider + func Register(name string, provider SessionsProvider) + func SessionInit(session string) + func Unregister(name string) + type Ackqueue struct + func (this *Ackqueue) Ack(msg message.Message) error + func (this *Ackqueue) Acked() []ackmsg + func (this *Ackqueue) Acked02() []ackmsg + func (this *Ackqueue) SetCluserTag(pktid uint16) bool + func (this *Ackqueue) Wait(msg message.Message, onComplete interface{}) error + type Manager struct + func NewManager(providerName string) (*Manager, error) + func (this *Manager) Close() error + func (this *Manager) Count() int + func (this *Manager) Del(id string) + func (this *Manager) Get(id string) (*Session, error) + func (this *Manager) New(id string) (*Session, error) + func (this *Manager) Save(id string) error + type Session struct + Cmsg *message.ConnectMessage + Pingack *Ackqueue + Pub1ack *Ackqueue + Pub2in *Ackqueue + Pub2out *Ackqueue + Retained *message.PublishMessage + Suback *Ackqueue + Unsuback *Ackqueue + Will *message.PublishMessage + func (this *Session) AddTopic(topic string, qos byte) error + func (this *Session) ID() string + func (this *Session) IDs() []byte + func (this *Session) Init(msg *message.ConnectMessage) error + func (this *Session) RemoveTopic(topic string) error + func (this *Session) RetainMessage(msg *message.PublishMessage) error + func (this *Session) Topics() ([]string, []byte, error) + func (this *Session) Update(msg *message.ConnectMessage) error + type SessionsProvider interface + Close func() error + Count func() int + Del func(id string) + Get func(id string) (*Session, error) + New func(id string) (*Session, error) + Save func(id string) error v0.0.2-temp Aug 19, 2021