dataUpdateEvent

Documentation

Index

• func ToGatewayPayload(status int32, in []*events.DeviceCore) *msgGateway.GatewayPayload
• type DataUpdateLogic
  • func NewPublishLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DataUpdateLogic
  • func (d *DataUpdateLogic) DeviceGatewayUpdate(info *events.GatewayUpdateInfo) error
  • func (d *DataUpdateLogic) DeviceLogLevelUpdate(info *events.DataUpdateInfo) error
  • func (d *DataUpdateLogic) DeviceRemoteConfigUpdate(info *events.DataUpdateInfo) error
  • func (d *DataUpdateLogic) ProductSchemaUpdate(info *events.DataUpdateInfo) error

Functions

func ToGatewayPayload

func ToGatewayPayload(status int32, in []*events.DeviceCore) *msgGateway.GatewayPayload

Types

type DataUpdateLogic

type DataUpdateLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewPublishLogic

func NewPublishLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DataUpdateLogic

func (*DataUpdateLogic) DeviceGatewayUpdate

func (d *DataUpdateLogic) DeviceGatewayUpdate(info *events.GatewayUpdateInfo) error

func (*DataUpdateLogic) DeviceLogLevelUpdate

func (d *DataUpdateLogic) DeviceLogLevelUpdate(info *events.DataUpdateInfo) error

func (*DataUpdateLogic) DeviceRemoteConfigUpdate

func (d *DataUpdateLogic) DeviceRemoteConfigUpdate(info *events.DataUpdateInfo) error

func (*DataUpdateLogic) ProductSchemaUpdate

func (d *DataUpdateLogic) ProductSchemaUpdate(info *events.DataUpdateInfo) error