kpt-pasture/dep/di_mqtt.go

package dep

import (
	"kpt-pasture/service/mqtt2"
)

/*func DIMqtt() (out MqttDependency) {
	container := DI()
	if err := container.Invoke(func(c MqttDependency) { out = c }); err != nil {
		panic(err)
	}
	return
}

type MqttDependency struct {
	dig.In

	DataEventEntry mqtt.DataEvent
}*/

func MqttRun() (out mqtt2.MqttServer) {
	container := DI()
	if err := container.Invoke(func(c mqtt2.MqttServer) { out = c }); err != nil {
		panic(err)
	}
	return
}