stgmqtt

type AppI interface {
	//Run 启动运行守护程序
	Run()
	//Stop 停止运行守护程序
	Stop()
	ReportStatus() error
	ReportEvent(containerName, appName string, event model.EventType, msg string) error
}

type Client interface {
	Run()

	AddTerminal(info Terminal) (iotDeviceID string, err error)
	DelTerminal(deviceSN string) error
	UpdateTerminalStatus(deviceSN string, online bool) error

	//ReportData 业务数据
	ReportData(deviceSN string, method string, data interface{}) error
	//ReportEvent 业务事件
	ReportEvent(deviceSN string, method string, data interface{}) error
}

type ContainerI interface {
	//Run 启动运行守护程序
	Run()
	//Stop 停止运行守护程序
	Stop()

	ReportStatus() error
	ReportEvent(containName string, event model.EventType, msg string) error
}

type DevInfo = model.DevInfo

type MessageHandler interface {
	OnConnect()
	OnConnectionLost(reason error)

	OnSysSetConfig(SystemConfig) error
}

type Options struct {
	InstVersion Version // stgmqtt实例的版本

	DevInfo      DevInfo
	SystemConfig SystemConfig

	IotPlatformAddr    string // 物联平台的地址
	IotPlatformVersion string // 物联平台的版本

	MqttVersion         string // 物联网协议版本
	MqttBrokers         []string
	MqttClientID        string
	MqttUsername        string
	MqttPassword        string
	MqttQOS             uint8
	MqttResponseTimeout time.Duration // 响应超时时间

	StoreDir string //持久化存储目录
}

type ServiceI interface {
	//Run 启动运行守护程序
	Run()
	//Stop 停止运行守护程序
	Stop()
	//ReportData 业务数据上报
	ReportData(iotDeviceID string, method string, data interface{}) error
	//ReportEvent 业务事件上报
	ReportEvent(iotDeviceID string, method string, data interface{}) error
}

type StgMqtt struct {
	sync.RWMutex

	SystemI
	TopoI
	ServiceI
	AppI
	ContainerI
	// contains filtered or unexported fields
}

type SystemConfig = model.SystemConfig

type SystemI interface {
	//Run 启动运行守护程序
	Run()
	//Stop 停止运行守护程序
	Stop()
	//LinkUp 设备接入
	LinkUp() error
	//LinkDown 设备断开
	LinkDown(reason string) error
	//GetIotCurTime 获取物联网平台当前时间
	GetIotCurTime() (time.Time, error)
	//ReportStatus 上报设备状态
	ReportStatus() error
	//ReportEvent 设备事件上报
	ReportEvent(event model.EventType, info string) error
}

type Terminal = model.TerminalInfo

type TopoI interface {
	//Run 启动运行守护程序
	Run()
	//Stop 停止运行守护程序
	Stop()
	AddTerminal(info model.TerminalInfo) (iotDeviceID string, err error)
	DelTerminal(deviceID string) error
	UpdateTerminalStatus(deviceID string, status model.DeviceStatus) error
}

type Version string