gemq

Nov 26, 2023

Changes in this version

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

+ type DialOptions struct

+ AppName string

+ Broker string

+ Password string

+ Username string

Apr 24, 2023

Changes in this version

+ var API = new(AuthAPI)

+ var ErrTokenTimeout = errors.New("等待emq服务器Token超时")

+ var Inc = new(Emq)

+ type AuthAPI struct

+ AuthFunc func(c iris.Context, d *mqttData) (err error)

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

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

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

+ type Emq struct

+ Config *config.Config

+ Logger *util.Logger

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

+ func (e *Emq) Constructor()

+ func (e *Emq) Dial()

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

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

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