Versions in this module Expand all Collapse all v1 v1.0.0 Sep 7, 2022 Changes in this version + func MessageToPublish(msg *Message, version packets.Version) *packets.Publish + type Message struct + ContentType string + CorrelationData []byte + Dup bool + MessageExpiry uint32 + PacketID packets.PacketID + Payload []byte + PayloadFormat packets.PayloadFormat + QoS uint8 + ResponseTopic string + Retained bool + SubscriptionIdentifier []uint32 + Topic string + UserProperties []packets.UserProperty + func MessageFromPublish(p *packets.Publish) *Message + func (m *Message) Copy() *Message + func (m *Message) TotalBytes(version packets.Version) uint32 + type Session struct + ClientID string + ConnectedAt time.Time + ExpiryInterval uint32 + Will *Message + WillDelayInterval uint32 + func (s *Session) IsExpired(now time.Time) bool + type Subscription struct + ID uint32 + NoLocal bool + QoS packets.QoS + RetainAsPublished bool + RetainHandling byte + ShareName string + TopicFilter string + func (s *Subscription) Copy() *Subscription + func (s *Subscription) GetFullTopicName() string + func (s *Subscription) Validate() error
Go to main page