Versions in this module Expand all Collapse all v1 v1.5.0 Feb 25, 2023 v1.2.0 Oct 12, 2022 v1.1.0 Sep 16, 2022 v1.0.0 Sep 10, 2022 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 + func (z *Client) MarshalMsg(b []byte) (o []byte, err error) + func (z *Client) Msgsize() (s int) + func (z *Client) UnmarshalMsg(bts []byte) (o []byte, err error) + type DeleteEntity interface + DeleteClient func(id string) error + DeleteInflight func(cid string, pid uint16) error + DeleteInflightBatch func(cid string, pid []uint16) error + DeleteRetained func(topic string) error + DeleteSubscription func(cid, filter string) error + type FixedHeader struct + Dup bool + Qos byte + Remaining int + Retain bool + Type byte + func (z *FixedHeader) MarshalMsg(b []byte) (o []byte, err error) + func (z *FixedHeader) Msgsize() (s int) + func (z *FixedHeader) UnmarshalMsg(bts []byte) (o []byte, err error) + type GenEntityId interface + GenInflightId func(cid string, pid uint16) string + GenRetainedId func(topic string) string + GenSubscriptionId func(cid, filter string) string + type KeyValue struct + Key string + Value string + func (z *KeyValue) UnmarshalMsg(bts []byte) (o []byte, err error) + func (z KeyValue) MarshalMsg(b []byte) (o []byte, err error) + func (z KeyValue) Msgsize() (s int) + type LWT struct + Message []byte + Qos byte + Retain bool + Topic string + func (z *LWT) MarshalMsg(b []byte) (o []byte, err error) + func (z *LWT) Msgsize() (s int) + func (z *LWT) UnmarshalMsg(bts []byte) (o []byte, err error) + type Message struct + Client string + FixedHeader FixedHeader + ID string + PacketID uint16 + Payload []byte + Properties Properties + Resends int + Sent int64 + T string + TopicName string + func (z *Message) MarshalMsg(b []byte) (o []byte, err error) + func (z *Message) Msgsize() (s int) + func (z *Message) UnmarshalMsg(bts []byte) (o []byte, err error) + 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(cid string, pid uint16) error + func (s *MockStore) DeleteInflightBatch(cid string, pid []uint16) error + func (s *MockStore) DeleteRetained(topic string) error + func (s *MockStore) DeleteSubscription(cid, filter string) error + func (s *MockStore) GenInflightId(cid string, pid uint16) string + func (s *MockStore) GenRetainedId(topic string) string + func (s *MockStore) GenSubscriptionId(cid, filter string) string + func (s *MockStore) Open() error + func (s *MockStore) ReadClientByCid(cid string) (v Client, err error) + func (s *MockStore) ReadClients() (v []Client, err error) + func (s *MockStore) ReadInflight() (v []Message, err error) + func (s *MockStore) ReadInflightByCid(cid string) (v []Message, err error) + func (s *MockStore) ReadRetained() (v []Message, err error) + func (s *MockStore) ReadRetainedByTopic(topic string) (v Message, err error) + func (s *MockStore) ReadServerInfo() (v ServerInfo, err error) + func (s *MockStore) ReadSubscriptions() (v []Subscription, err error) + func (s *MockStore) ReadSubscriptionsByCid(cid string) (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 + func (z *MockStore) MarshalMsg(b []byte) (o []byte, err error) + func (z *MockStore) Msgsize() (s int) + func (z *MockStore) UnmarshalMsg(bts []byte) (o []byte, err error) + type Properties struct + ContentType string + CorrelationData []byte + Expiry int64 + PayloadFormat *byte + ResponseTopic string + UserProperties []KeyValue + func (z *Properties) MarshalMsg(b []byte) (o []byte, err error) + func (z *Properties) Msgsize() (s int) + func (z *Properties) UnmarshalMsg(bts []byte) (o []byte, err error) + type ReadAll interface + 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) + type ReadClient interface + ReadClientByCid func(cid string) (v Client, err error) + ReadInflightByCid func(cid string) (v []Message, err error) + ReadRetainedByTopic func(topic string) (v Message, err error) + ReadSubscriptionsByCid func(cid string) (v []Subscription, err error) + type ServerInfo struct + ID string + type Store interface + Close func() + Open func() error + type Subscription struct + Client string + Filter string + ID string + NoLocal bool + QoS byte + RetainAsPublished bool + RetainHandling byte + T string + func (z *Subscription) MarshalMsg(b []byte) (o []byte, err error) + func (z *Subscription) Msgsize() (s int) + func (z *Subscription) UnmarshalMsg(bts []byte) (o []byte, err error) + type WriteEntity interface + 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
Go to main page