sensor_server

type ISServer interface {
	Start()
	Stop()
	AddSensor(Sensor)
	RemoveSensor(Sensor)
	Write(Sensor, []byte)
}

type ISensor interface {
	Sn() string                 // 获取编号
	Session() Session           // 会话
	Ping() []byte               // PING包
	OnRegister(sn string) error // 注册成功
	OnLine()                    // 上线
	OffLine()                   // 掉线
	OnError(error)              // 出错
	OnData([]byte)              // 来数据
}

type Sensor struct {
	Authed bool
	// contains filtered or unexported fields
}

type SensorServer struct {
	// contains filtered or unexported fields
}

type SensorWorker struct {
	Ctx    context.Context
	Cancel context.CancelFunc
	// contains filtered or unexported fields
}

type Session struct {
	Id        string
	Transport net.Conn
}