connection

Oct 11, 2019

Changes in this version

+ var ErrConnectionNack = errors.New("connection: nack")

Oct 28, 2018

Changes in this version

type Option

+ func Permissions(val vlauth.Permissions) Option

Jul 3, 2018

Changes in this version

type Option

+ func Persistence(val persistence.Packets) Option

type SessionCallbacks

+ SignalOnline func()

Apr 22, 2018

Changes in this version

+ type AuthParams struct

+ AuthData []byte

+ AuthMethod string

+ Reason packet.ReasonCode

+ 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 packet.ProtocolVersion

+ Will *packet.Publish

+ WillDelay uint32

type DisconnectParams

+ Packets persistence.PersistedPackets

+ type Initial interface

+ Accept func() (chan interface{}, error)

+ Acknowledge func(p *packet.ConnAck, opts ...Option) bool

+ Send func(packet.Provider) error

+ Session func() Session

+ type OnAuthCb func(string, *AuthParams) (packet.Provider, 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 RetainAvailable(val bool) Option

+ func RxQuota(val int32) Option

+ func TxQuota(val int32) Option

+ type Session interface

+ LoadRemaining func(g, q *list.List)

+ Publish func(string, *packet.Publish)

+ SetOptions func(opts ...Option) error

+ Start func() error

+ type SessionCallbacks interface

+ SignalConnectionClose func(DisconnectParams)

+ SignalDisconnect func(*packet.Disconnect) (packet.Provider, error)

+ SignalOffline func()

+ SignalPublish func(*packet.Publish) error

+ SignalSubscribe func(*packet.Subscribe) (packet.Provider, error)

+ SignalUnSubscribe func(*packet.UnSubscribe) (packet.Provider, error)

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