export

Documentation

Index

• type Export
• type MqttExport
  • func (export *MqttExport) ExportTo(deviceData plugin.DeviceData)
  • func (export *MqttExport) Init() error
  • func (export *MqttExport) IsReady() bool
  • func (export *MqttExport) SendStatusChangeNotification(deviceName string, online bool) error

Types

type Export

type Export interface {
	Init() error

	ExportTo(deviceData plugin.DeviceData)

	SendStatusChangeNotification(deviceName string, online bool) error

	IsReady() bool
}

type MqttExport

type MqttExport struct {
	Broker   string `json:"broker"`
	Username string `json:"username"`
	Password string `json:"password"`
	ClientID string `json:"client_id"`

	ExportTopic string
	// contains filtered or unexported fields
}

func (*MqttExport) ExportTo

func (export *MqttExport) ExportTo(deviceData plugin.DeviceData)

ExportTo 导出消息：写入Edgex总线、MQTT上云

func (*MqttExport) Init

func (export *MqttExport) Init() error

func (*MqttExport) IsReady

func (export *MqttExport) IsReady() bool

func (*MqttExport) SendStatusChangeNotification

func (export *MqttExport) SendStatusChangeNotification(deviceName string, online bool) error