Versions in this module Expand all Collapse all v0 v0.0.1 Oct 17, 2023 Changes in this version + type Hook struct + Log *slog.Logger + func (h *Hook) ID() string + func (h *Hook) Init(config any) error + func (h *Hook) OnClientExpired(cl *mqtt.Client) + func (h *Hook) OnLWTSent(cl *mqtt.Client, pk packets.Packet) + func (h *Hook) OnPacketRead(cl *mqtt.Client, pk packets.Packet) (packets.Packet, error) + func (h *Hook) OnPacketSent(cl *mqtt.Client, pk packets.Packet, b []byte) + 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) OnStarted() + func (h *Hook) OnStopped() + func (h *Hook) Provides(b byte) bool + func (h *Hook) SetOpts(l *slog.Logger, opts *mqtt.HookOptions) + 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) + type Options struct + ShowPacketData bool + ShowPasswords bool + ShowPings bool
Go to main page