dtmanager

Documentation

Index

• Constants
• Variables
• func DealDeviceTwin(context *dtcontext.DTContext, deviceID string, eventID string, ...) error
• func DealGetTwin(context *dtcontext.DTContext, deviceID string, payload []byte) error
• func DealMsgAttr(context *dtcontext.DTContext, deviceID string, ...) dttype.DealAttrResult
• func DealMsgTwin(context *dtcontext.DTContext, deviceID string, ...) dttype.DealTwinResult
• func SyncDeviceFromSqlite(context *dtcontext.DTContext, deviceID string) error
• func UpdateDeviceAttr(context *dtcontext.DTContext, deviceID string, ...) (interface{}, error)
• func Updated(context *dtcontext.DTContext, deviceID string, payload []byte)
• type CallBack
• type CommWorker
  • func (cw CommWorker) Start()
• type DMIWorker
  • func (dw DMIWorker) Start()
• type DTWorker
• type DeviceWorker
  • func (dw DeviceWorker) Start()
• type MemWorker
  • func (mw MemWorker) Start()
• type TwinWorker
  • func (tw TwinWorker) Start()
• type Worker

Constants

const (
	//RestDealType update from mqtt
	RestDealType = 0
	//SyncDealType update from cloud sync
	SyncDealType = 1
	//DetailDealType detail update from cloud
	DetailDealType = 2
	//SyncTwinDeleteDealType twin delete when sync
	SyncTwinDeleteDealType = 3
	//DealActual deal actual
	DealActual = 1
	//DealExpected deal expected
	DealExpected = 0
)

Variables

var (
	//ActionCallBack map for action to callback
	ActionCallBack map[string]CallBack
)

Functions

func DealDeviceTwin

func DealDeviceTwin(context *dtcontext.DTContext, deviceID string, eventID string, msgTwin map[string]*dttype.MsgTwin, dealType int) error

DealDeviceTwin deal device twin

func DealGetTwin

func DealGetTwin(context *dtcontext.DTContext, deviceID string, payload []byte) error

DealGetTwin deal get twin event

func DealMsgAttr

func DealMsgAttr(context *dtcontext.DTContext, deviceID string, msgAttrs map[string]*dttype.MsgAttr, dealType int) dttype.DealAttrResult

DealMsgAttr get diff,0:update, 1:detail

func DealMsgTwin

func DealMsgTwin(context *dtcontext.DTContext, deviceID string, msgTwins map[string]*dttype.MsgTwin, dealType int) dttype.DealTwinResult

DealMsgTwin get diff while updating twin

func SyncDeviceFromSqlite

func SyncDeviceFromSqlite(context *dtcontext.DTContext, deviceID string) error

SyncDeviceFromSqlite sync device from sqlite

func UpdateDeviceAttr

func UpdateDeviceAttr(context *dtcontext.DTContext, deviceID string, attributes map[string]*dttype.MsgAttr, baseMessage dttype.BaseMessage, dealType int) (interface{}, error)

UpdateDeviceAttr update device attributes

func Updated

func Updated(context *dtcontext.DTContext, deviceID string, payload []byte)

Updated update the snapshot

Types

type CallBack

type CallBack func(*dtcontext.DTContext, string, interface{}) error

CallBack for deal

type CommWorker

type CommWorker struct {
	Worker
	Group string
}

CommWorker deal app response event

func (CommWorker) Start

func (cw CommWorker) Start()

Start worker

type DMIWorker

type DMIWorker struct {
	Worker
	Group string
	// contains filtered or unexported fields
}

TwinWorker deal twin event

func (DMIWorker) Start

func (dw DMIWorker) Start()

Start worker

type DTWorker

type DTWorker interface {
	Start()
}

DTWorker worker for devicetwin

type DeviceWorker

type DeviceWorker struct {
	Worker
	Group string
}

DeviceWorker deal device event

func (DeviceWorker) Start

func (dw DeviceWorker) Start()

Start worker

type MemWorker

type MemWorker struct {
	Worker
	Group string
}

MemWorker deal membership event

func (MemWorker) Start

func (mw MemWorker) Start()

Start worker

type TwinWorker

type TwinWorker struct {
	Worker
	Group string
}

TwinWorker deal twin event

func (TwinWorker) Start

func (tw TwinWorker) Start()

Start worker

type Worker

type Worker struct {
	ReceiverChan  chan interface{}
	ConfirmChan   chan interface{}
	HeartBeatChan chan interface{}
	DTContexts    *dtcontext.DTContext
}

Worker actual