topics

Feb 24, 2021

Changes in this version

+ type Index struct

+ Root *Leaf

+ func New() *Index

+ func (x *Index) Messages(filter string) []packets.Packet

+ func (x *Index) RetainMessage(msg packets.Packet) int64

+ func (x *Index) Subscribe(filter, client string, qos byte) bool

+ func (x *Index) Subscribers(topic string) Subscriptions

+ func (x *Index) Unsubscribe(filter, client string) bool

+ type Leaf struct

+ Clients map[string]byte

+ Filter string

+ Key string

+ Leaves map[string]*Leaf

+ Message packets.Packet

+ Parent *Leaf

+ type Subscriptions map[string]byte