libCodec

Documentation

Index

• func InterfaceToBytes(key interface{}) ([]byte, error)
• func Register(name string, c Codec)
• type Codec
  • func HttpCodec() Codec
  • func MqttCodec() Codec
  • func Open(name string) (Codec, error)
• type DeviceData
• type DeviceDecodeMsg
  • func (d *DeviceDecodeMsg) GetDataList() []*DeviceData
  • func (d *DeviceDecodeMsg) GetDeviceInfo() *model.DeviceAllInfo
  • func (d *DeviceDecodeMsg) GetEventList() []*DeviceEvent
• type DeviceEvent

Functions

func InterfaceToBytes

func InterfaceToBytes(key interface{}) ([]byte, error)

func Register

func Register(name string, c Codec)

Types

type Codec

type Codec interface {
	Encode(ctx context.Context, rawData interface{}) (*DeviceDecodeMsg, error)
	Decode(ctx context.Context, msg DeviceData) (interface{}, error)
	Save(ctx context.Context, dmesg *DeviceDecodeMsg) error
}

func HttpCodec

func HttpCodec() Codec

func MqttCodec

func MqttCodec() Codec

func Open

func Open(name string) (Codec, error)

type DeviceData

type DeviceData struct {
	CategoryId int
	Name       string
	Type       int
	Data       interface{}
	Time       *gtime.Time
	Ratio      string
}

type DeviceDecodeMsg

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

func (*DeviceDecodeMsg) GetDataList

func (d *DeviceDecodeMsg) GetDataList() []*DeviceData

func (*DeviceDecodeMsg) GetDeviceInfo

func (d *DeviceDecodeMsg) GetDeviceInfo() *model.DeviceAllInfo

func (*DeviceDecodeMsg) GetEventList

func (d *DeviceDecodeMsg) GetEventList() []*DeviceEvent

type DeviceEvent

type DeviceEvent struct {
	Name string
	Data interface{}
}