Versions in this module Expand all Collapse all v1 v1.0.0 Sep 7, 2022 Changes in this version + func NewServer(proto string, path string) *server + func Print() + func Regsiter(name string, f Handle) + func Server() *server + func Service(ctx context.Context, name string, data []byte) (p []byte, err error) + type Handle func(ctx context.Context, data []byte) ([]byte, error) + type Leaf struct + Clients map[string]byte + Filter string + Key string + Leaves map[string]*Leaf + Message MessagePacket + Parent *Leaf + type MessagePacket struct + Payload []byte + Retain bool + TopicName string + Topics []string + type MuxBroker struct + func (m *MuxBroker) Accept(id uint32) (net.Conn, error) + func (m *MuxBroker) AcceptAndServe(id uint32, v interface{}) + func (m *MuxBroker) Close() error + func (m *MuxBroker) Dial(id uint32) (net.Conn, error) + func (m *MuxBroker) NextId() uint32 + func (m *MuxBroker) Run() + type Plugin struct + func NewPlugin(path string, id string, cfg common.PluginCfg) *Plugin + func (p *Plugin) GetId() string + func (p *Plugin) SetSocketDirectory(dir string) + func (p *Plugin) SetTimeout(t time.Duration) + func (p *Plugin) Start() + func (p *Plugin) Stop() + func (p *Plugin) String() string + func (p *Plugin) Wait(ctx context.Context, pidCh chan<- int, exe string, params string) + type PublicMsg struct + type Session interface + Close func() + ConnectedAt func() time.Time + Connection func() net.Conn + Disconnect func() + Version func() int + type Subscriptions map[string]byte + type Topic struct + Root *Leaf + func TopicNew() *Topic + func (x *Topic) Messages(filter string) []MessagePacket + func (x *Topic) RetainMessage(msg MessagePacket) int64 + func (x *Topic) Subscribe(filter, client string, qos byte) bool + func (x *Topic) Subscribers(topic string) Subscriptions + func (x *Topic) Unsubscribe(filter, client string) bool