gemq

package

v1.0.0 Latest Latest Go to latest Published: Nov 26, 2023 License: MIT Imports: 14 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/atcharles/glibs

Documentation ¶

Index ¶

Variables
func DailWithOption(opt DialOptions) (c mqtt.Client, err error)
type AuthAPI
type DialOptions
type Emq

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	// ErrTokenTimeout declare
	ErrTokenTimeout = errors.New("等待emq服务器Token超时")
	Inc             = new(Emq)
)

View Source

var API = new(AuthAPI)

Functions ¶

func DailWithOption ¶ added in v1.0.0

func DailWithOption(opt DialOptions) (c mqtt.Client, err error)

Types ¶

type AuthAPI ¶

type AuthAPI struct {
	AuthFunc func(c iris.Context, d *mqttData) (err error)
}

func (*AuthAPI) ACL ¶

func (a *AuthAPI) ACL(d *mqttData) (err error)

ACL ......

func (*AuthAPI) Auth ¶

func (a *AuthAPI) Auth(c iris.Context, d *mqttData) (err error)

Auth ......

func (*AuthAPI) Handle ¶

func (a *AuthAPI) Handle(r iris.Party) iris.Party

Handle ...

type DialOptions ¶ added in v1.0.0

type DialOptions struct {
	AppName  string
	Broker   string
	Username string
	Password string
}

type Emq ¶

type Emq struct {
	Config *config.Config `inject:""`
	Logger util.ItfLogger `inject:""`
	// contains filtered or unexported fields
}

Emq ...

func (*Emq) Client ¶

func (e *Emq) Client() mqtt.Client

Client ...

func (*Emq) Constructor ¶

func (e *Emq) Constructor()

Constructor ...

func (*Emq) Dial ¶

func (e *Emq) Dial()

Dial ...

func (*Emq) EmqSuperAuth ¶

func (e *Emq) EmqSuperAuth() (username, password string)

EmqSuperAuth ...

func (*Emq) PublishC ¶

func (e *Emq) PublishC(topic string, payload interface{})

PublishC ... publish in channel

func (e *Emq) Subscribe(topic string, callback mqtt.MessageHandler) (err error)

Subscribe ...

Source Files ¶

View all Source files

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