Versions in this module Expand all Collapse all v0 v0.0.5 Jul 9, 2025 v0.0.4 Jun 30, 2025 v0.0.3 Jun 30, 2025 Changes in this version type Message + Client string v0.0.1 Sep 9, 2024 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 Serializable interface + MarshalBinary func() (data []byte, err error) + UnmarshalBinary func([]byte) error + 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