Documentation ¶
Index ¶
Constants ¶
View Source
const (
DeliveryKey = "mqtt.Message"
)
Variables ¶
This section is empty.
Functions ¶
Types ¶
type MQ ¶
type MessageHandler ¶
func ContextTask ¶
func ContextTask(f task.Task, ctx context.Context) MessageHandler
func (MessageHandler) Do ¶
func (a MessageHandler) Do(m mqtt.Message)
func (MessageHandler) Then ¶
func (a MessageHandler) Then(b MessageHandler) MessageHandler
Click to show internal directories.
Click to hide internal directories.