dtclient

package

v1.6.1 Latest Latest Go to latest Published: May 4, 2021 License: Apache-2.0 Imports: 4 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/sellto/kubeedge

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func AddDeviceTrans(adds []Device, addAttrs []DeviceAttr, addTwins []DeviceTwin) error
func DeleteDeviceAttr(deviceID string, name string) error
func DeleteDeviceAttrByDeviceID(deviceID string) error
func DeleteDeviceByID(id string) error
func DeleteDeviceTrans(deletes []string) error
func DeleteDeviceTwin(deviceID string, name string) error
func DeleteDeviceTwinByDeviceID(deviceID string) error
func DeviceAttrTrans(adds []DeviceAttr, deletes []DeviceDelete, updates []DeviceAttrUpdate) error
func DeviceTwinTrans(adds []DeviceTwin, deletes []DeviceDelete, updates []DeviceTwinUpdate) error
func InitDBTable(module core.Module)
func QueryDevice(key string, condition string) (*[]Device, error)
func QueryDeviceAll() (*[]Device, error)
func QueryDeviceAttr(key string, condition string) (*[]DeviceAttr, error)
func QueryDeviceTwin(key string, condition string) (*[]DeviceTwin, error)
func SaveDevice(doc *Device) error
func SaveDeviceAttr(doc *DeviceAttr) error
func SaveDeviceTwin(doc *DeviceTwin) error
func UpdateDeviceAttrField(deviceID string, name string, col string, value interface{}) error
func UpdateDeviceAttrFields(deviceID string, name string, cols map[string]interface{}) error
func UpdateDeviceAttrMulti(updates []DeviceAttrUpdate) error
func UpdateDeviceField(deviceID string, col string, value interface{}) error
func UpdateDeviceFields(deviceID string, cols map[string]interface{}) error
func UpdateDeviceMulti(updates []DeviceUpdate) error
func UpdateDeviceTwinField(deviceID string, name string, col string, value interface{}) error
func UpdateDeviceTwinFields(deviceID string, name string, cols map[string]interface{}) error
func UpdateDeviceTwinMulti(updates []DeviceTwinUpdate) error
type Device
type DeviceAttr
type DeviceAttrUpdate
type DeviceDelete
type DeviceTwin
type DeviceTwinUpdate
type DeviceUpdate

Constants ¶

View Source

const (
	//DeviceTableName device table
	DeviceTableName = "device"
	//DeviceAttrTableName device table
	DeviceAttrTableName = "device_attr"
	//DeviceTwinTableName device table
	DeviceTwinTableName = "device_twin"
)

Variables ¶

This section is empty.

Functions ¶

func AddDeviceTrans ¶

func AddDeviceTrans(adds []Device, addAttrs []DeviceAttr, addTwins []DeviceTwin) error

AddDeviceTrans the transaction of add device

func DeleteDeviceAttr ¶

func DeleteDeviceAttr(deviceID string, name string) error

DeleteDeviceAttr delete device attr

func DeleteDeviceAttrByDeviceID ¶

func DeleteDeviceAttrByDeviceID(deviceID string) error

DeleteDeviceAttrByDeviceID delete device attr

func DeleteDeviceByID ¶

func DeleteDeviceByID(id string) error

DeleteDeviceByID delete device by id

func DeleteDeviceTrans ¶

func DeleteDeviceTrans(deletes []string) error

DeleteDeviceTrans the transaction of delete device

func DeleteDeviceTwin ¶

func DeleteDeviceTwin(deviceID string, name string) error

DeleteDeviceTwin delete device twin

func DeleteDeviceTwinByDeviceID ¶

func DeleteDeviceTwinByDeviceID(deviceID string) error

DeleteDeviceTwinByDeviceID delete device twin

func DeviceAttrTrans ¶

func DeviceAttrTrans(adds []DeviceAttr, deletes []DeviceDelete, updates []DeviceAttrUpdate) error

DeviceAttrTrans transaction of device attr

func DeviceTwinTrans ¶

func DeviceTwinTrans(adds []DeviceTwin, deletes []DeviceDelete, updates []DeviceTwinUpdate) error

DeviceTwinTrans transaction of device twin

func InitDBTable ¶

func InitDBTable(module core.Module)

InitDBTable create table

func QueryDevice ¶

func QueryDevice(key string, condition string) (*[]Device, error)

QueryDevice query Device

func QueryDeviceAll ¶

func QueryDeviceAll() (*[]Device, error)

QueryDeviceAll query twin

func QueryDeviceAttr ¶

func QueryDeviceAttr(key string, condition string) (*[]DeviceAttr, error)

QueryDeviceAttr query Device

func QueryDeviceTwin ¶

func QueryDeviceTwin(key string, condition string) (*[]DeviceTwin, error)

QueryDeviceTwin query Device

func SaveDevice ¶

func SaveDevice(doc *Device) error

SaveDevice save device

func SaveDeviceAttr ¶

func SaveDeviceAttr(doc *DeviceAttr) error

SaveDeviceAttr save device attributes

func SaveDeviceTwin ¶

func SaveDeviceTwin(doc *DeviceTwin) error

SaveDeviceTwin save device twin

func UpdateDeviceAttrField ¶

func UpdateDeviceAttrField(deviceID string, name string, col string, value interface{}) error

UpdateDeviceAttrField update special field

func UpdateDeviceAttrFields ¶

func UpdateDeviceAttrFields(deviceID string, name string, cols map[string]interface{}) error

UpdateDeviceAttrFields update special fields

func UpdateDeviceAttrMulti ¶

func UpdateDeviceAttrMulti(updates []DeviceAttrUpdate) error

UpdateDeviceAttrMulti update device attr multi

func UpdateDeviceField ¶

func UpdateDeviceField(deviceID string, col string, value interface{}) error

UpdateDeviceField update special field

func UpdateDeviceFields ¶

func UpdateDeviceFields(deviceID string, cols map[string]interface{}) error

UpdateDeviceFields update special fields

func UpdateDeviceMulti ¶

func UpdateDeviceMulti(updates []DeviceUpdate) error

UpdateDeviceMulti update device multi

func UpdateDeviceTwinField ¶

func UpdateDeviceTwinField(deviceID string, name string, col string, value interface{}) error

UpdateDeviceTwinField update special field

func UpdateDeviceTwinFields ¶

func UpdateDeviceTwinFields(deviceID string, name string, cols map[string]interface{}) error

UpdateDeviceTwinFields update special fields

func UpdateDeviceTwinMulti ¶

func UpdateDeviceTwinMulti(updates []DeviceTwinUpdate) error

UpdateDeviceTwinMulti update device twin multi

Types ¶

type Device ¶

type Device struct {
	ID          string `orm:"column(id); size(64); pk"`
	Name        string `orm:"column(name); null; type(text)"`
	Description string `orm:"column(description); null; type(text)"`
	State       string `orm:"column(state); null; type(text)"`
	LastOnline  string `orm:"column(last_online); null; type(text)"`
}

Device the struct of device

type DeviceAttr ¶

type DeviceAttr struct {
	ID          int64  `orm:"column(id);size(64);auto;pk"`
	DeviceID    string `orm:"column(deviceid); null; type(text)"`
	Name        string `orm:"column(name);null;type(text)"`
	Description string `orm:"column(description);null;type(text)"`
	Value       string `orm:"column(value);null;type(text)"`
	Optional    bool   `orm:"column(optional);null;type(integer)"`
	AttrType    string `orm:"column(attr_type);null;type(text)"`
	Metadata    string `orm:"column(metadata);null;type(text)"`
}

DeviceAttr the struct of device attributes

type DeviceAttrUpdate ¶

type DeviceAttrUpdate struct {
	DeviceID string
	Name     string
	Cols     map[string]interface{}
}

DeviceAttrUpdate the struct for updating device attr

type DeviceDelete ¶

type DeviceDelete struct {
	DeviceID string
	Name     string
}

DeviceDelete the struct for deleting device

type DeviceTwin ¶

type DeviceTwin struct {
	ID              int64  `orm:"column(id);size(64);auto;pk"`
	DeviceID        string `orm:"column(deviceid); null; type(text)"`
	Name            string `orm:"column(name);null;type(text)"`
	Description     string `orm:"column(description);null;type(text)"`
	Expected        string `orm:"column(expected);null;type(text)"`
	Actual          string `orm:"column(actual);null;type(text)"`
	ExpectedMeta    string `orm:"column(expected_meta);null;type(text)"`
	ActualMeta      string `orm:"column(actual_meta);null;type(text)"`
	ExpectedVersion string `orm:"column(expected_version);null;type(text)"`
	ActualVersion   string `orm:"column(actual_version);null;type(text)"`
	Optional        bool   `orm:"column(optional);null;type(integer)"`
	AttrType        string `orm:"column(attr_type);null;type(text)"`
	Metadata        string `orm:"column(metadata);null;type(text)"`
}

DeviceTwin the struct of device twin

type DeviceTwinUpdate ¶

type DeviceTwinUpdate struct {
	DeviceID string
	Name     string
	Cols     map[string]interface{}
}

DeviceTwinUpdate the struct for updating device twin

type DeviceUpdate ¶

type DeviceUpdate struct {
	DeviceID string
	Cols     map[string]interface{}
}

DeviceUpdate the struct for updating device

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL