devicetwin

Documentation

Index

• Variables
• func Register(deviceTwin *v1alpha1.DeviceTwin, nodeName string)
• func SyncDeviceFromSqlite(context *dtcontext.DTContext, deviceID string) error
• func SyncSqlite(context *dtcontext.DTContext) error
• type DeviceTwin
  • func (dt *DeviceTwin) Enable() bool
  • func (dt *DeviceTwin) Group() string
  • func (dt *DeviceTwin) Name() string
  • func (dt *DeviceTwin) RegisterDTModule(name string)
  • func (dt *DeviceTwin) Start()

Variables

var (
	//EventActionMap map for event to action
	EventActionMap map[string]map[string]string
	//ActionModuleMap map for action to module
	ActionModuleMap map[string]string
)

Functions

func Register

func Register(deviceTwin *v1alpha1.DeviceTwin, nodeName string)

Register register devicetwin

func SyncDeviceFromSqlite

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

SyncDeviceFromSqlite sync device from sqlite

func SyncSqlite

func SyncSqlite(context *dtcontext.DTContext) error

SyncSqlite sync sqlite

Types

type DeviceTwin

type DeviceTwin struct {
	HeartBeatToModule map[string]chan interface{}
	DTContexts        *dtcontext.DTContext
	DTModules         map[string]dtmodule.DTModule
	// contains filtered or unexported fields
}

DeviceTwin the module

func (*DeviceTwin) Enable

func (dt *DeviceTwin) Enable() bool

Enable indicates whether this module is enabled

func (*DeviceTwin) Group

func (dt *DeviceTwin) Group() string

Group get group of the module

func (*DeviceTwin) Name

func (dt *DeviceTwin) Name() string

Name get name of the module

func (*DeviceTwin) RegisterDTModule

func (dt *DeviceTwin) RegisterDTModule(name string)

RegisterDTModule register dtmodule

func (*DeviceTwin) Start

func (dt *DeviceTwin) Start()

Start run the module