Documentation
¶
Index ¶
- func Auth(ctx context.Context, svcCtx *svc.ServiceContext, in devices.Core) (devices.Auth, error)
- func BindToDeviceCoreDos(in []*dm.DeviceGatewayBindDevice) (ret []*devices.Core)
- func BindToDeviceCoreEvents(in []*dm.DeviceGatewayBindDevice) (ret []*events.DeviceCore)
- func CheckAffordance(po *relationDB.DmSchemaCore, cs *relationDB.DmCommonSchema) error
- func FillAreaDeviceCount(ctx context.Context, svcCtx *svc.ServiceContext, areaIDPaths ...string) error
- func FillAreaGroupCount(ctx context.Context, svcCtx *svc.ServiceContext, areaID int64) error
- func FillProjectDeviceCount(ctx context.Context, svcCtx *svc.ServiceContext, projectIDs ...int64) error
- func Init(svcCtx *svc.ServiceContext)
- func SchemaAccess(ctx context.Context, svcCtx *svc.ServiceContext, authType def.AuthType, ...) (outParam map[string]any, err error)
- func ToCustomTopicDo(info *dm.CustomTopic) *productCustom.CustomTopic
- func ToCustomTopicPb(info *productCustom.CustomTopic) *dm.CustomTopic
- func ToCustomTopicsDo(info []*dm.CustomTopic) (ret []*productCustom.CustomTopic)
- func ToCustomTopicsPb(info []*productCustom.CustomTopic) (ret []*dm.CustomTopic)
- func ToDeviceCoreDo(core *dm.DeviceCore) *devices.Core
- func ToDeviceCoreDos(in []*dm.DeviceCore) (ret []*devices.Core)
- func ToDeviceCoreEvents(in []*dm.DeviceCore) (ret []*events.DeviceCore)
- func ToDeviceCores(in []*dm.DeviceCore) []*devices.Core
- func ToDeviceInfo(ctx context.Context, svcCtx *svc.ServiceContext, in *relationDB.DmDeviceInfo) *dm.DeviceInfo
- func ToDmPoint(point *stores.Point) *dm.Point
- func ToGatewayDevice(gateway *devices.Core, subDevice []*devices.Core) (ret []*relationDB.DmGatewayDevice)
- func ToGatewayPayload(status def.GatewayStatus, in []*devices.Core) *msgGateway.GatewayPayload
- func ToPageInfo(info *dm.PageInfo) *stores.PageInfo
- func ToProductCategoryPb(ctx context.Context, svcCtx *svc.ServiceContext, ...) *dm.ProductCategory
- func ToProductInfo(ctx context.Context, svcCtx *svc.ServiceContext, pi *relationDB.DmProductInfo) *dm.ProductInfo
- func ToProductSchemaPo(info *dm.ProductSchemaInfo) *relationDB.DmSchemaInfo
- func ToProductSchemaRpc(info *relationDB.DmSchemaInfo) *dm.ProductSchemaInfo
- func ToProtocolConfigFieldsPb(in protocol.ConfigFields) (ret []*dm.ProtocolConfigField)
- func ToProtocolConfigFieldsPo(in []*dm.ProtocolConfigField) (ret protocol.ConfigFields)
- func ToProtocolConfigInfosPb(in protocol.ConfigInfos) (ret []*dm.ProtocolConfigInfo)
- func ToProtocolConfigInfosPo(in []*dm.ProtocolConfigInfo) (ret protocol.ConfigInfos)
- func ToProtocolInfoPb(in *relationDB.DmProtocolInfo) *dm.ProtocolInfo
- func ToProtocolInfoPo(in *dm.ProtocolInfo) *relationDB.DmProtocolInfo
- func ToStorePoint(point *dm.Point) stores.Point
- func ToTimeRange(in *dm.TimeRange) *def.TimeRange
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BindToDeviceCoreDos ¶
func BindToDeviceCoreDos(in []*dm.DeviceGatewayBindDevice) (ret []*devices.Core)
func BindToDeviceCoreEvents ¶
func BindToDeviceCoreEvents(in []*dm.DeviceGatewayBindDevice) (ret []*events.DeviceCore)
func CheckAffordance ¶ added in v1.0.4
func CheckAffordance(po *relationDB.DmSchemaCore, cs *relationDB.DmCommonSchema) error
func FillAreaDeviceCount ¶
func FillAreaGroupCount ¶
func FillProjectDeviceCount ¶
func Init ¶ added in v1.0.5
func Init(svcCtx *svc.ServiceContext)
func SchemaAccess ¶
func ToCustomTopicDo ¶
func ToCustomTopicDo(info *dm.CustomTopic) *productCustom.CustomTopic
func ToCustomTopicPb ¶
func ToCustomTopicPb(info *productCustom.CustomTopic) *dm.CustomTopic
func ToCustomTopicsDo ¶
func ToCustomTopicsDo(info []*dm.CustomTopic) (ret []*productCustom.CustomTopic)
func ToCustomTopicsPb ¶
func ToCustomTopicsPb(info []*productCustom.CustomTopic) (ret []*dm.CustomTopic)
func ToDeviceCoreDo ¶
func ToDeviceCoreDo(core *dm.DeviceCore) *devices.Core
func ToDeviceCoreDos ¶
func ToDeviceCoreDos(in []*dm.DeviceCore) (ret []*devices.Core)
func ToDeviceCoreEvents ¶
func ToDeviceCoreEvents(in []*dm.DeviceCore) (ret []*events.DeviceCore)
func ToDeviceCores ¶
func ToDeviceCores(in []*dm.DeviceCore) []*devices.Core
func ToDeviceInfo ¶
func ToDeviceInfo(ctx context.Context, svcCtx *svc.ServiceContext, in *relationDB.DmDeviceInfo) *dm.DeviceInfo
func ToGatewayDevice ¶
func ToGatewayDevice(gateway *devices.Core, subDevice []*devices.Core) (ret []*relationDB.DmGatewayDevice)
func ToGatewayPayload ¶
func ToGatewayPayload(status def.GatewayStatus, in []*devices.Core) *msgGateway.GatewayPayload
func ToProductCategoryPb ¶
func ToProductCategoryPb(ctx context.Context, svcCtx *svc.ServiceContext, info *relationDB.DmProductCategory, children []*relationDB.DmProductCategory) *dm.ProductCategory
func ToProductInfo ¶
func ToProductInfo(ctx context.Context, svcCtx *svc.ServiceContext, pi *relationDB.DmProductInfo) *dm.ProductInfo
func ToProductSchemaPo ¶
func ToProductSchemaPo(info *dm.ProductSchemaInfo) *relationDB.DmSchemaInfo
func ToProductSchemaRpc ¶
func ToProductSchemaRpc(info *relationDB.DmSchemaInfo) *dm.ProductSchemaInfo
func ToProtocolConfigFieldsPb ¶
func ToProtocolConfigFieldsPb(in protocol.ConfigFields) (ret []*dm.ProtocolConfigField)
func ToProtocolConfigFieldsPo ¶
func ToProtocolConfigFieldsPo(in []*dm.ProtocolConfigField) (ret protocol.ConfigFields)
func ToProtocolConfigInfosPb ¶
func ToProtocolConfigInfosPb(in protocol.ConfigInfos) (ret []*dm.ProtocolConfigInfo)
func ToProtocolConfigInfosPo ¶
func ToProtocolConfigInfosPo(in []*dm.ProtocolConfigInfo) (ret protocol.ConfigInfos)
func ToProtocolInfoPb ¶
func ToProtocolInfoPb(in *relationDB.DmProtocolInfo) *dm.ProtocolInfo
func ToProtocolInfoPo ¶
func ToProtocolInfoPo(in *dm.ProtocolInfo) *relationDB.DmProtocolInfo
Types ¶
This section is empty.
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.