event

type Event interface {
	Fire(topic string, datas [][]byte) error
	Register(...EventJob)
}

type EventConf struct {
	Provider string
	Mqtt     *mqtt.MqttConf
}

type EventDI interface {
	NewEvent(serviceName string, l log.Logger) Event
}

type EventHandler func(data []byte) error

type EventJob interface {
	GetTopic() string
	GetHandler() EventHandler
}