Versions in this module Expand all Collapse all v0 v0.2.6 Mar 20, 2019 Changes in this version + type AuthParams struct + AuthData []byte + AuthMethod string + Reason mqttp.ReasonCode + type Callbacks struct + OnStop func(string, bool) + type ConnectParams struct + CleanStart bool + Durable bool + Error error + ExpireIn *uint32 + ID string + IDGen bool + KeepAlive uint16 + MaxTxPacketSize uint32 + Password []byte + SendQuota uint16 + Username []byte + Version mqttp.ProtocolVersion + Will *mqttp.Publish + type DisconnectParams struct + Packets persistence.PersistedPackets + Reason mqttp.ReasonCode + type Initial interface + Accept func() (chan interface{}, error) + Acknowledge func(p *mqttp.ConnAck, opts ...Option) bool + Send func(mqttp.IFace) error + Session func() Session + func New(opts ...Option) Initial + type OnAuthCb func(string, *AuthParams) (mqttp.IFace, error) + type Option func(*impl) error + func AttachSession(val SessionCallbacks) Option + func KeepAlive(val int) Option + func MaxRxPacketSize(val uint32) Option + func MaxRxTopicAlias(val uint16) Option + func MaxTxPacketSize(val uint32) Option + func MaxTxTopicAlias(val uint16) Option + func Metric(val systree.PacketsMetric) Option + func NetConn(val transport.Conn) Option + func OfflineQoS0(val bool) Option + func OnAuth(val OnAuthCb) Option + func Permissions(val vlauth.Permissions) Option + func Persistence(val persistence.Packets) Option + func RetainAvailable(val bool) Option + func RxQuota(val int32) Option + func TxQuota(val int32) Option + type Session interface + Publish func(string, *mqttp.Publish) + SetOptions func(opts ...Option) error + type SessionCallbacks interface + SignalConnectionClose func(DisconnectParams) + SignalDisconnect func(*mqttp.Disconnect) (mqttp.IFace, error) + SignalOffline func() + SignalOnline func() + SignalPublish func(*mqttp.Publish) error + SignalSubscribe func(*mqttp.Subscribe) (mqttp.IFace, error) + SignalUnSubscribe func(*mqttp.UnSubscribe) (mqttp.IFace, error) + type WillConfig struct + Message []byte + QoS mqttp.QosType + Retain bool + Topic string