broker

package

v4.1.4 Latest Latest Go to latest Published: Apr 21, 2024 License: MIT Imports: 22 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/zgwit/iot-master

Links

Open Source Insights

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
type Broker
type Gateway

Constants ¶

This section is empty.

Variables ¶

View Source

var Server *mochi.Server

Functions ¶

func CustomOpenConnectionFn ¶ added in v4.1.1

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

func GinBridge ¶

func GinBridge(ctx *gin.Context)

func Shutdown ¶ added in v4.1.0

func Shutdown() (err error)

func Startup ¶ added in v4.1.0

func Startup() error

Types ¶

type Auth ¶ added in v4.1.0

type Auth struct {
	mqtt.HookBase
}

func (*Auth) ID ¶ added in v4.1.0

func (h *Auth) ID() string

ID returns the ID of the hook.

func (*Auth) OnACLCheck ¶ added in v4.1.0

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

OnACLCheck returns true/allowed for all checks.

func (*Auth) OnConnectAuthenticate ¶ added in v4.1.0

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

OnConnectAuthenticate returns true/allowed for all requests.

func (*Auth) Provides ¶ added in v4.1.0

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

Provides indicates which hook methods this hook provides.

type Broker ¶ added in v4.0.18

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 ¶ added in v4.0.18

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"`
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL