Versions in this module Expand all Collapse all v0 v0.2.2 Oct 26, 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 int32 + type Message struct + Delay int32 + DeliveryMode uint8 + MessageID uint16 + Payload []byte + TTL int64 + Topic string + func (m *Message) Size() int64 + type MessageIds struct + func NewMessageIds() MessageIds + func (mids *MessageIds) FreeID(id MID) + func (mids *MessageIds) GetType(id MID) utp.MessageType + func (mids *MessageIds) NextID(pktType utp.MessageType) MID + func (mids *MessageIds) Reset() + func (mids *MessageIds) ResumeID(id MID) + type Stat struct + Counter int + ID []byte + Topic string + type Stats struct + func NewStats() *Stats + func (s *Stats) All() []Stat + func (s *Stats) Decrement(topic string, key string) (last bool, id []byte) + func (s *Stats) Exist(key string) (ok bool) + func (s *Stats) Increment(topic string, 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 v0.2.2-alpha Oct 26, 2021
Go to main page