message

Documentation

Index

• type DataProcessEngine
  • func GetEngine() *DataProcessEngine
  • func (d DataProcessEngine) OnDataDownLink(target model.Target, props map[string]interface{})
  • func (d DataProcessEngine) OnDataUpLink(upLink *model.LinkMessage)
  • func (d *DataProcessEngine) SetCallback(cb OnDownLink)
• type OnDownLink

Types

type DataProcessEngine

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

func GetEngine

func GetEngine() *DataProcessEngine

func (DataProcessEngine) OnDataDownLink

func (d DataProcessEngine) OnDataDownLink(target model.Target, props map[string]interface{})

func (DataProcessEngine) OnDataUpLink

func (d DataProcessEngine) OnDataUpLink(upLink *model.LinkMessage)

func (*DataProcessEngine) SetCallback

func (d *DataProcessEngine) SetCallback(cb OnDownLink)

type OnDownLink

type OnDownLink func(target model.Target, data []byte)