Versions in this module Expand all Collapse all v2 v2.6.6 Oct 23, 2024 Changes in this version type Message + Client string v2.6.5 Jul 30, 2024 v2.6.4 May 19, 2024 v2.6.3 Apr 30, 2024 v2.6.2 Apr 16, 2024 v2.6.1 Apr 1, 2024 Changes in this version + type Serializable interface + MarshalBinary func() (data []byte, err error) + UnmarshalBinary func([]byte) error v2.6.0 Mar 18, 2024 v2.4.6 Feb 5, 2024 v2.4.5 Jan 11, 2024 v2.4.4 Dec 22, 2023 v2.4.3 Dec 12, 2023 v2.4.2 Oct 24, 2023 v2.4.1 Oct 2, 2023 v2.4.0 Sep 8, 2023 v2.3.0 Jul 31, 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