plugin

type Connector interface {
	Send(data interface{}) (err error) // 发送数据
	Release() (err error)              // 释放连接资源
}

type DeviceData struct {
	DeviceName string      `json:"device_name"`
	Values     []PointData `json:"values"`
}

type EncodeMode string

type H map[string]interface{}

type OnReceiveHandler func(plugin Plugin, raw interface{}) (result interface{}, err error)

type Plugin interface {
	// Initialize 初始化日志、配置、接收回调
	Initialize(logger *zap.Logger, c config.Config, handler OnReceiveHandler, ls *lua.LState) (err error)
	// ProtocolAdapter 协议适配器
	ProtocolAdapter() ProtocolAdapter
	// Connector 连接器
	Connector(deviceName, pointName string) (connector Connector, err error)
	// Destroy 销毁驱动
	Destroy() error
}

type PointData struct {
	PointName string      `json:"name"`  // 点位名称
	Type      string      `json:"type"`  // 点位值类型
	Value     interface{} `json:"value"` // 点位值
}

type ProtocolAdapter interface {
	Encode(deviceName string, mode EncodeMode, value PointData) (res interface{}, err error) // 编码
	Decode(raw interface{}) (res []DeviceData, err error)                                    // 解码
}