gemq

Documentation

Index

• Variables
• func DailWithOption(opt DialOptions) (c mqtt.Client, err error)
• type AuthAPI
  • 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 DialOptions
• type Emq
  • 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)

Variables

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

var API = new(AuthAPI)

Functions

func DailWithOption

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

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 (*Emq) Subscribe

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

Subscribe ...