Versions in this module Expand all Collapse all v2 v2.6.0 Aug 8, 2024 v2.5.6 Jun 25, 2024 v2.5.5 Mar 21, 2024 v2.5.4 Mar 14, 2024 v2.5.3 Mar 14, 2024 v2.5.2 Dec 14, 2023 v2.5.1 Dec 13, 2023 v2.5.0 Oct 15, 2023 v2.4.1 Oct 6, 2023 v2.4.0 Aug 23, 2023 v2.3.9 Aug 1, 2023 v2.3.8 Jul 23, 2023 v2.3.7 Jul 11, 2023 v2.3.5 Jun 1, 2023 v2.3.0 May 12, 2023 Changes in this version + const ClientKey + const InflightKey + const RetainedKey + const SubscriptionKey + const SysInfoKey + var ErrDBFileNotOpen = errors.New("db file not open") + type Client struct + Clean bool + ID string + Listener string + Properties ClientProperties + ProtocolVersion byte + Remote string + T string + Username []byte + Will ClientWill + func (d *Client) UnmarshalBinary(data []byte) error + func (d Client) MarshalBinary() (data []byte, err error) + type ClientProperties struct + AuthenticationData []byte + AuthenticationMethod string + MaximumPacketSize uint32 + ReceiveMaximum uint16 + RequestProblemInfo byte + RequestProblemInfoFlag bool + RequestResponseInfo byte + SessionExpiryInterval uint32 + SessionExpiryIntervalFlag bool + TopicAliasMaximum uint16 + User []packets.UserProperty + type ClientWill struct + Flag uint32 + Payload []byte + Qos byte + Retain bool + TopicName string + User []packets.UserProperty + WillDelayInterval uint32 + type Message struct + Created int64 + FixedHeader packets.FixedHeader + ID string + Origin string + PacketID uint16 + Payload []byte + Properties MessageProperties + Sent int64 + T string + TopicName string + func (d *Message) ToPacket() packets.Packet + func (d *Message) UnmarshalBinary(data []byte) error + func (d Message) MarshalBinary() (data []byte, err error) + type MessageProperties struct + ContentType string + CorrelationData []byte + MessageExpiryInterval uint32 + PayloadFormat byte + PayloadFormatFlag bool + ResponseTopic string + SubscriptionIdentifier []int + TopicAlias uint16 + User []packets.UserProperty + type Subscription struct + Client string + Filter string + ID string + Identifier int + NoLocal bool + Qos byte + RetainAsPublished bool + RetainHandling byte + T string + func (d *Subscription) UnmarshalBinary(data []byte) error + func (d Subscription) MarshalBinary() (data []byte, err error) + type SystemInfo struct + ID string + T string + func (d *SystemInfo) UnmarshalBinary(data []byte) error + func (d SystemInfo) MarshalBinary() (data []byte, err error)
Go to main page