Versions in this module Expand all Collapse all v0 v0.0.3 Sep 21, 2017 Changes in this version + var ErrOverflow = errors.New("session: overflow") + var ErrPersistence = errors.New("session: error during persistence restore") + type Callbacks struct + OnStop func(string, bool) + type Config struct + ExpireIn *uint32 + ID string + KillOnDisconnect bool + Messenger types.TopicMessenger + OnDisconnect onDisconnect + Subscriber subscriber.ConnectionProvider + WillDelay uint32 + type DisconnectParams struct + Desc *netpoll.Desc + ExpireAt *uint32 + Reason packet.ReasonCode + Will bool + type PreConfig struct + Auth auth.SessionPermissions + AuthData []byte + AuthMethod string + Conn net.Conn + Desc *netpoll.Desc + KeepAlive uint16 + MaxRxPacketSize uint32 + MaxRxTopicAlias uint16 + MaxTxPacketSize uint32 + MaxTxTopicAlias uint16 + Metric systree.Metric + OfflineQoS0 bool + PreserveOrder bool + RetainAvailable bool + SendQuota int32 + StartReceiving func(*netpoll.Desc, netpoll.CallbackFn) error + State persistence.Packets + StopReceiving func(*netpoll.Desc) error + Username string + Version packet.ProtocolVersion + WaitForData func(*netpoll.Desc) error + type Type struct + func New(c *Config) (s *Type, err error) + func (s *Type) Start() + func (s *Type) Stop(reason packet.ReasonCode) + type WillConfig struct + Message []byte + QoS packet.QosType + Retain bool + Topic string v0.0.2-beta Sep 1, 2017