Versions in this module Expand all Collapse all v0 v0.0.1 Sep 9, 2024 Changes in this version + type Hook struct + func (h *Hook) Debugf(m string, v ...any) + func (h *Hook) Errorf(m string, v ...any) + func (h *Hook) ID() string + func (h *Hook) Infof(m string, v ...any) + func (h *Hook) Init(config any) error + func (h *Hook) OnClientExpired(cl *mqtt.Client) + func (h *Hook) OnDisconnect(cl *mqtt.Client, _ error, expire bool) + func (h *Hook) OnQosComplete(cl *mqtt.Client, pk packets.Packet) + func (h *Hook) OnQosDropped(cl *mqtt.Client, pk packets.Packet) + func (h *Hook) OnQosPublish(cl *mqtt.Client, pk packets.Packet, sent int64, resends int) + func (h *Hook) OnRetainMessage(cl *mqtt.Client, pk packets.Packet, r int64) + func (h *Hook) OnRetainedExpired(filter string) + func (h *Hook) OnSessionEstablished(cl *mqtt.Client, pk packets.Packet) + func (h *Hook) OnSubscribed(cl *mqtt.Client, pk packets.Packet, reasonCodes []byte) + func (h *Hook) OnSysInfoTick(sys *system.Info) + func (h *Hook) OnUnsubscribed(cl *mqtt.Client, pk packets.Packet) + func (h *Hook) OnWillSent(cl *mqtt.Client, pk packets.Packet) + func (h *Hook) Provides(b byte) bool + func (h *Hook) Stop() error + func (h *Hook) StoredClients() (v []storage.Client, err error) + func (h *Hook) StoredInflightMessages() (v []storage.Message, err error) + func (h *Hook) StoredRetainedMessages() (v []storage.Message, err error) + func (h *Hook) StoredSubscriptions() (v []storage.Subscription, err error) + func (h *Hook) StoredSysInfo() (v storage.SystemInfo, err error) + func (h *Hook) Warningf(m string, v ...any) + type Options struct + GcDiscardRatio float64 + GcInterval int64 + Options *badgerdb.Options + Path string + type Serializable interface + MarshalBinary func() (data []byte, err error) + UnmarshalBinary func([]byte) error
Go to main page