logic

package
v1.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 22, 2024 License: AGPL-3.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Auth

func Auth(ctx context.Context, svcCtx *svc.ServiceContext, in devices.Core) (devices.Auth, error)

func BindToDeviceCoreDos

func BindToDeviceCoreDos(in []*dm.DeviceGatewayBindDevice) (ret []*devices.Core)

func BindToDeviceCoreEvents

func BindToDeviceCoreEvents(in []*dm.DeviceGatewayBindDevice) (ret []*events.DeviceCore)

func FillAreaDeviceCount

func FillAreaDeviceCount(ctx context.Context, svcCtx *svc.ServiceContext, areaIDPaths ...string) error

func FillAreaGroupCount

func FillAreaGroupCount(ctx context.Context, svcCtx *svc.ServiceContext, areaID int64) error

func FillProjectDeviceCount

func FillProjectDeviceCount(ctx context.Context, svcCtx *svc.ServiceContext, projectIDs ...int64) error

func SchemaAccess

func SchemaAccess(ctx context.Context, svcCtx *svc.ServiceContext, authType def.AuthType, dev devices.Core, param map[string]any) (outParam map[string]any, err error)

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 ToDmPoint

func ToDmPoint(point *stores.Point) *dm.Point

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 ToPageInfo

func ToPageInfo(info *dm.PageInfo) *stores.PageInfo

func ToProductInfo

func ToProductInfo(ctx context.Context, svcCtx *svc.ServiceContext, pi *relationDB.DmProductInfo) *dm.ProductInfo

func ToProductSchemaPo

func ToProductSchemaPo(info *dm.ProductSchemaInfo) *relationDB.DmProductSchema

func ToProductSchemaRpc

func ToProductSchemaRpc(info *relationDB.DmProductSchema) *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

func ToStorePoint

func ToStorePoint(point *dm.Point) stores.Point

func ToTimeRange

func ToTimeRange(in *dm.TimeRange) *def.TimeRange

Types

This section is empty.

Jump to

Keyboard shortcuts

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