broker

Documentation

Index

• Constants
• func GinBridge(ctx *gin.Context)
• func Publish(topic string, payload any) (err error)
• func Shutdown() error
• func Startup() (err error)
• type Hook
  • func (h *Hook) ID() string
  • func (h *Hook) OnACLCheck(cl *mqtt.Client, topic string, write bool) bool
  • func (h *Hook) OnConnectAuthenticate(cl *mqtt.Client, pk packets.Packet) bool
  • func (h *Hook) OnDisconnect(cl *mqtt.Client, err error, expire bool)
  • func (h *Hook) OnSubscribed(cl *mqtt.Client, pk packets.Packet, reasonCodes []byte)
  • func (h *Hook) OnUnsubscribed(cl *mqtt.Client, pk packets.Packet)
  • func (h *Hook) Provides(b byte) bool

Constants

const MODULE = "broker"

Functions

func GinBridge

func GinBridge(ctx *gin.Context)

func Publish

func Publish(topic string, payload any) (err error)

func Shutdown

func Shutdown() error

func Startup

func Startup() (err error)

Types

type Hook

type Hook struct {
	mqtt.HookBase
}

func (*Hook) ID

func (h *Hook) ID() string

func (*Hook) OnACLCheck

func (h *Hook) OnACLCheck(cl *mqtt.Client, topic string, write bool) bool

func (*Hook) OnConnectAuthenticate

func (h *Hook) OnConnectAuthenticate(cl *mqtt.Client, pk packets.Packet) bool

func (*Hook) OnDisconnect

func (h *Hook) OnDisconnect(cl *mqtt.Client, err error, expire bool)

func (*Hook) OnSubscribed

func (h *Hook) OnSubscribed(cl *mqtt.Client, pk packets.Packet, reasonCodes []byte)

func (*Hook) OnUnsubscribed

func (h *Hook) OnUnsubscribed(cl *mqtt.Client, pk packets.Packet)

func (*Hook) Provides

func (h *Hook) Provides(b byte) bool