Versions in this module Expand all Collapse all v0 v0.2.0 Aug 20, 2021 v0.1.1 Jul 8, 2021 Changes in this version + const CONNECT + const Contract + const DISCONNECT + const PINGREQ + const PINGRESP + const PUBLISH + const SUBSCRIBE + const SubscriberDirect + const SubscriberRemote + const UNSUBSCRIBE + type MID uint16 + type Message struct + Delay int32 + DeliveryMode uint8 + MessageID uint16 + Payload []byte + TTL int64 + Topic []byte + func (m *Message) Size() int64 + type MessageIds struct + func NewMessageIds() MessageIds + func (mids *MessageIds) FreeID(id uint16) + func (mids *MessageIds) GetType(id uint16) uint8 + func (mids *MessageIds) NextID(pktType uint8) uint16 + func (mids *MessageIds) Reset() + func (mids *MessageIds) ResumeID(id uint16) + type Stat struct + Counter int + ID []byte + Topic []byte + type Stats struct + func NewStats() *Stats + func (s *Stats) All() []Stat + func (s *Stats) Decrement(topic []byte, key string) (last bool, id []byte) + func (s *Stats) Exist(key string) (ok bool) + func (s *Stats) Increment(topic []byte, key string, id []byte) (first bool) + type Subscriber interface + ID func() string + SendMessage func(*Message) bool + Type func() SubscriberType + type SubscriberType uint8 + type TopicAnyCount uint8
Go to main page