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 GenerateReceiveChanAction(action, identity, id, content string) chan interface{}
• 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 CaseHeartBeatWorkerStr
  • func GenerateHeartBeatCase(name, group string, channel chan interface{}) CaseHeartBeatWorkerStr
• type CaseWorkerStr
  • func GenerateStartActionCase(name string, channelPresent chan interface{}) CaseWorkerStr
• type CasesMsgWorkerStr
• 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
)

const (
	Delay            = 10 * time.Millisecond
	MaxRetries       = 5
	Identity         = "identity"
	Message          = "message"
	Msg              = "msg"
	Action           = "action"
	TestAction       = "testAction"
	ActionPresent    = "StartTest-ActionPresentInActionCallback"
	ActionNotPresent = "StartTest-ActionNotPresentInActionCallback"
	PingHeartBeat    = "StartTest-PingInHeartBeatChannel"
	StopHeartBeat    = "StartTest-StopInHeartBeatChannel"
	Group            = "group"
)

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 GenerateReceiveChanAction

func GenerateReceiveChanAction(action, identity, id, content string) chan interface{}

GenerateReceiveChanAction generates receive channel action

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 CaseHeartBeatWorkerStr

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

CaseHeartBeatWorkerStr is case struct of worker for heartbeat

func GenerateHeartBeatCase

func GenerateHeartBeatCase(name, group string, channel chan interface{}) CaseHeartBeatWorkerStr

GenerateHeartBeatCase generates heart beat action case

type CaseWorkerStr

type CaseWorkerStr struct {
	Worker Worker
	// contains filtered or unexported fields
}

CaseWorkerStr is case struct of worker

func GenerateStartActionCase

func GenerateStartActionCase(name string, channelPresent chan interface{}) CaseWorkerStr

GenerateStartActionCase generates start action case

type CasesMsgWorkerStr

type CasesMsgWorkerStr []struct {
	// contains filtered or unexported fields
}

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