emqx

Documentation

Index

• func InitClient(opt *MQTTOptions)
• type ConnectHandler
• type ConnectLostHandler
• type Context
• type Engine
  • func NewEngine(topic string, wildcard bool) (eng Engine)
  • func (e *Engine) Register(url string, handler HandlerFunc)
  • func (e *Engine) UseAfter(handler ...HookHandler)
  • func (e *Engine) UseBefore(handler ...HookHandler)
• type HandlerFunc
• type HookHandler
• type MQTT
  • func GetConnect() *MQTT
  • func (c *MQTT) Connect() error
  • func (c *MQTT) Publish(topic string, data []byte) error
• type MQTTOptions
  • func Default(addr, id, username, password string) *MQTTOptions
  • func (m *MQTTOptions) Register(engine ...Engine)
• type PublishHook

Functions

func InitClient

func InitClient(opt *MQTTOptions)

Types

type ConnectHandler

type ConnectHandler func(mqtt.Client)

type ConnectLostHandler

type ConnectLostHandler func(mqtt.Client, error)

type Context

type Context struct {
	URI     string
	Topic   string
	Buffer  []byte
	Message string
}

type Engine

type Engine struct {
	Topic    string
	TopicLen int
	Wildcard bool
	Shared   bool

	BeforeHook []HookHandler
	AfterHook  []HookHandler
	// contains filtered or unexported fields
}

func NewEngine

func NewEngine(topic string, wildcard bool) (eng Engine)

func (*Engine) Register

func (e *Engine) Register(url string, handler HandlerFunc)

func (*Engine) UseAfter

func (e *Engine) UseAfter(handler ...HookHandler)

func (*Engine) UseBefore

func (e *Engine) UseBefore(handler ...HookHandler)

type HandlerFunc

type HandlerFunc func(*Context)

type HookHandler

type HookHandler func(*Context)

type MQTT

type MQTT struct {
	// contains filtered or unexported fields
}

func GetConnect

func GetConnect() *MQTT

get

func (*MQTT) Connect

func (c *MQTT) Connect() error

func (*MQTT) Publish

func (c *MQTT) Publish(topic string, data []byte) error

type MQTTOptions

type MQTTOptions struct {
	Addr               string
	ID                 string
	Username           string
	Password           string
	KeepAlive          time.Duration
	SetPingTimeout     time.Duration
	Engine             []Engine
	ConnectHandler     ConnectHandler
	ConnectLostHandler ConnectLostHandler
}

func Default

func Default(addr, id, username, password string) *MQTTOptions

func (*MQTTOptions) Register

func (m *MQTTOptions) Register(engine ...Engine)

type PublishHook

type PublishHook func()