logic

package

v0.10.7 Latest Latest Go to latest Published: Oct 9, 2024 License: AGPL-3.0 Imports: 23 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

gitee.com/i-Things/things

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
devicegroup
deviceinteract
devicemanage
devicemsg
otamanage
productmanage
protocolmanage
remoteconfig
schemamanage
userdevice

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