broker

Documentation

Index

• Variables
• func CustomOpenConnectionFn(uri *url.URL, options paho.ClientOptions) (net.Conn, error)
• func GinBridge(ctx *gin.Context)
• func Shutdown() (err error)
• func Startup() error
• type Auth
  • func (h *Auth) ID() string
  • func (h *Auth) OnACLCheck(cl *mqtt.Client, topic string, write bool) bool
  • func (h *Auth) OnConnectAuthenticate(cl *mqtt.Client, pk packets.Packet) bool
  • func (h *Auth) Provides(b byte) bool
• type Broker
• type Gateway

Variables

var Server *mochi.Server

Functions

func CustomOpenConnectionFn

func CustomOpenConnectionFn(uri *url.URL, options paho.ClientOptions) (net.Conn, error)

func GinBridge

func GinBridge(ctx *gin.Context)

func Shutdown

func Shutdown() (err error)

func Startup

func Startup() error

Types

type Auth

type Auth struct {
	mqtt.HookBase
}

func (*Auth) ID

func (h *Auth) ID() string

ID returns the ID of the hook.

func (*Auth) OnACLCheck

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

OnACLCheck returns true/allowed for all checks.

func (*Auth) OnConnectAuthenticate

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

OnConnectAuthenticate returns true/allowed for all requests.

func (*Auth) Provides

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

Provides indicates which hook methods this hook provides.

type Broker

type Broker struct {
	Id          string    `json:"id" xorm:"pk"`
	Name        string    `json:"name"`
	Description string    `json:"description,omitempty"`
	Port        int       `json:"port,omitempty"` //TODO 添加TLS证书
	Disabled    bool      `json:"disabled,omitempty"`
	Created     time.Time `json:"created,omitempty" xorm:"created"`
}

type Gateway

type Gateway struct {
	Id          string `json:"id" xorm:"pk"`
	Name        string `json:"name"`
	Description string `json:"description,omitempty"`
	Username    string `json:"username,omitempty"`
	Password    string `json:"password,omitempty"`

	Disabled bool      `json:"disabled,omitempty"`
	Created  time.Time `json:"created,omitempty" xorm:"created"`
}