emqx

type ConnectHandler func(mqtt.Client)

type ConnectLostHandler func(mqtt.Client, error)

type Context struct {
	context.Context
	Client  mqtt.Client
	Message mqtt.Message
	URI     string
	Topic   string
	Buffer  []byte
	Body    string
}

type Engine struct {
	*Options
	Topic      string
	TopicLen   int
	Wildcard   bool
	Shared     bool
	ShareGroup string

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

type HandlerFunc func(*Context)

type HookHandler func(*Context)

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

type Options struct {
	Addr               string
	ID                 string
	Username           string
	Password           string
	KeepAlive          time.Duration
	SetPingTimeout     time.Duration
	Engine             []*Engine
	ConnectHandler     ConnectHandler
	ConnectLostHandler ConnectLostHandler
	Logger             logger.Interface
}

type PublishHook func()