Versions in this module Expand all Collapse all v1 v1.0.6 Mar 17, 2021 v1.0.5 Mar 17, 2021 v1.0.4 Mar 17, 2021 v1.0.3 Feb 24, 2021 v1.0.2 Feb 24, 2021 v1.0.1 Feb 24, 2021 Changes in this version + const KClient + const KInflight + const KRetained + const KServerInfo + const KSubscription + type Client struct + ClientID string + ID string + LWT LWT + Listener string + T string + Username []byte + type FixedHeader struct + Dup bool + Qos byte + Remaining int + Retain bool + Type byte + type LWT struct + Message []byte + Qos byte + Retain bool + Topic string + type Message struct + Client string + FixedHeader FixedHeader + ID string + PacketID uint16 + Payload []byte + Resends int + Sent int64 + T string + TopicName string + type MockStore struct + Closed bool + Fail map[string]bool + FailOpen bool + Opened bool + func (s *MockStore) Close() + func (s *MockStore) DeleteClient(id string) error + func (s *MockStore) DeleteInflight(id string) error + func (s *MockStore) DeleteRetained(id string) error + func (s *MockStore) DeleteSubscription(id string) error + func (s *MockStore) Open() error + func (s *MockStore) ReadClients() (v []Client, err error) + func (s *MockStore) ReadInflight() (v []Message, err error) + func (s *MockStore) ReadRetained() (v []Message, err error) + func (s *MockStore) ReadServerInfo() (v ServerInfo, err error) + func (s *MockStore) ReadSubscriptions() (v []Subscription, err error) + func (s *MockStore) WriteClient(v Client) error + func (s *MockStore) WriteInflight(v Message) error + func (s *MockStore) WriteRetained(v Message) error + func (s *MockStore) WriteServerInfo(v ServerInfo) error + func (s *MockStore) WriteSubscription(v Subscription) error + type ServerInfo struct + ID string + type Store interface + Close func() + DeleteClient func(id string) error + DeleteInflight func(id string) error + DeleteRetained func(id string) error + DeleteSubscription func(id string) error + Open func() error + ReadClients func() (v []Client, err error) + ReadInflight func() (v []Message, err error) + ReadRetained func() (v []Message, err error) + ReadServerInfo func() (v ServerInfo, err error) + ReadSubscriptions func() (v []Subscription, err error) + WriteClient func(v Client) error + WriteInflight func(v Message) error + WriteRetained func(v Message) error + WriteServerInfo func(v ServerInfo) error + WriteSubscription func(v Subscription) error + type Subscription struct + Client string + Filter string + ID string + QoS byte + T string
Go to main page