dtcontext

Documentation

Index

• type DTContext
  • func InitDTContext() (*DTContext, error)
  • func (dtc *DTContext) BuildModelMessage(group string, parentID string, resource string, operation string, ...) *model.Message
  • func (dtc *DTContext) CommTo(dtmName string, content interface{}) error
  • func (dtc *DTContext) GetDevice(deviceID string) (*dttype.Device, bool)
  • func (dtc *DTContext) GetMutex(deviceID string) (*sync.Mutex, bool)
  • func (dtc *DTContext) HeartBeat(dtmName string, content interface{}) error
  • func (dtc *DTContext) IsDeviceExist(deviceID string) bool
  • func (dtc *DTContext) Lock(deviceID string) bool
  • func (dtc *DTContext) LockAll()
  • func (dtc *DTContext) Send(identity string, action string, module string, msg *model.Message) error
  • func (dtc *DTContext) Unlock(deviceID string) bool
  • func (dtc *DTContext) UnlockAll()

Types

type DTContext

type DTContext struct {
	GroupID        string
	NodeName       string
	CommChan       map[string]chan interface{}
	ConfirmChan    chan interface{}
	ConfirmMap     *sync.Map
	ModulesHealth  *sync.Map
	ModulesContext *context.Context
	DeviceList     *sync.Map
	DeviceMutex    *sync.Map
	Mutex          *sync.RWMutex
	// DBConn *dtclient.Conn
	State string
}

DTContext context for devicetwin

func InitDTContext

func InitDTContext() (*DTContext, error)

InitDTContext init dtcontext

func (*DTContext) BuildModelMessage

func (dtc *DTContext) BuildModelMessage(group string, parentID string, resource string, operation string, content interface{}) *model.Message

BuildModelMessage build mode messages

func (*DTContext) CommTo

func (dtc *DTContext) CommTo(dtmName string, content interface{}) error

CommTo communicate

func (*DTContext) GetDevice

func (dtc *DTContext) GetDevice(deviceID string) (*dttype.Device, bool)

GetDevice get device

func (*DTContext) GetMutex

func (dtc *DTContext) GetMutex(deviceID string) (*sync.Mutex, bool)

GetMutex get mutex

func (*DTContext) HeartBeat

func (dtc *DTContext) HeartBeat(dtmName string, content interface{}) error

HeartBeat hearbeat to dtcontroller

func (*DTContext) IsDeviceExist

func (dtc *DTContext) IsDeviceExist(deviceID string) bool

IsDeviceExist judge device is exist

func (*DTContext) Lock

func (dtc *DTContext) Lock(deviceID string) bool

Lock get the lock of the device

func (*DTContext) LockAll

func (dtc *DTContext) LockAll()

LockAll get all lock

func (*DTContext) Send

func (dtc *DTContext) Send(identity string, action string, module string, msg *model.Message) error

Send send result

func (*DTContext) Unlock

func (dtc *DTContext) Unlock(deviceID string) bool

Unlock remove the lock of the device

func (*DTContext) UnlockAll

func (dtc *DTContext) UnlockAll()

UnlockAll get all lock