Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InitClient ¶
func InitClient(opt *MQTTOptions)
Types ¶
type ConnectHandler ¶
type ConnectHandler func(mqtt.Client)
type ConnectLostHandler ¶
type ConnectLostHandler func(mqtt.Client, error)
type Engine ¶
type Engine struct { Topic string TopicLen int Wildcard bool BeforeHook []HookHandler AfterHook []HookHandler // contains filtered or unexported fields }
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 MQTTOptions ¶ added in v1.2.10
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 ¶ added in v1.2.10
func (m *MQTTOptions) Register(engine ...Engine)
type PublishHook ¶
type PublishHook func()
Click to show internal directories.
Click to hide internal directories.