kpt-pasture/dep/di_mqtt.go

package dep

import (
	"kpt-pasture/service/mqtt"

	"go.uber.org/dig"
)

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

// MqttDependency 依赖注入结构体
type MqttDependency struct {
	dig.In

	MqttServer mqtt.IMqttServer
}