gateway

Documentation

Index

• func Shutdown() error
• func Startup() error
• func Table() *table.Table
• type Gateway
• 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) OnPublish(cl *mqtt.Client, pk packets.Packet) (packets.Packet, error)
  • func (h *Hook) Provides(b byte) bool

Functions

func Shutdown

func Shutdown() error

func Startup

func Startup() error

func Table

func Table() *table.Table

Types

type Gateway

type Gateway struct {
	Id       string `json:"_id,omitempty"`
	Name     string `json:"name,omitempty"`
	Username string `json:"username,omitempty"`
	Password string `json:"password,omitempty"`
}

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) OnPublish

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

func (*Hook) Provides

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