serial

type Command struct {
	Mode        plugin.EncodeMode             // (必填)模式
	UUId        string                        //(必填)指令唯一标识
	OutputFrame string                        // (必填)输出帧
	Callback    func(inputFrame []byte) error //(必填)串口响应回调
}

type ConnectionConfig struct {
	plugin.BaseConnection
	Address     string `json:"address"`     // 地址：例如：127.0.0.1:502
	BaudRate    uint   `json:"baudRate"`    // 波特率（仅串口模式）
	DataBits    uint   `json:"dataBits"`    // 数据位（仅串口模式）
	StopBits    uint   `json:"stopBits"`    // 停止位（仅串口模式）
	Parity      string `json:"parity"`      // 奇偶性校验（仅串口模式）
	MinInterval uint16 `json:"minInterval"` // 最小读取间隔
	Timeout     uint16 `json:"timeout"`     // 请求超时
	Retry       int    `json:"retry"`       // 重试次数
}

type Connector struct {
	Config *ConnectionConfig
	Plugin *Plugin

	Client serialPort
	// contains filtered or unexported fields
}

type Error string

type Plugin struct {
	Config config.Config
	// contains filtered or unexported fields
}

type ProtocolAdapter interface {
	//初始化采集任务组
	InitTimerGroup(connector *Connector) []TimerGroup
	//执行采集任务
	ExecuteTimerGroup(group *TimerGroup) error

	SendCommand(cmd Command) error

	DriverBoxEncode(deviceId string, mode plugin.EncodeMode, values ...plugin.PointData) (res []Command, err error)
}

type TimerGroup struct {
	//采集组唯一ID
	UUID       string
	LatestTime time.Time
	//记录最近连续超时次数
	TimeOutCount int
	//采集间隔
	Duration time.Duration
	//关联设备ID
	Devices []string
}