relationDB

Documentation

Index

• func Migrate() error
• func NewShadowRepo(in any) shadow.Repo
• func ToShadowDo(in *DiDeviceShadow) *shadow.Info
• func ToShadowsDo(in []*DiDeviceShadow) []*shadow.Info
• type DiDeviceShadow
  • func ToShadowPo(info *shadow.Info) *DiDeviceShadow
  • func (m *DiDeviceShadow) TableName() string
• type ShadowRepo
  • func (p *ShadowRepo) FindByFilter(ctx context.Context, f shadow.Filter) ([]*shadow.Info, error)
  • func (p *ShadowRepo) MultiDelete(ctx context.Context, f shadow.Filter) error
  • func (p *ShadowRepo) MultiUpdate(ctx context.Context, data []*shadow.Info) error

Functions

func Migrate

func Migrate() error

func NewShadowRepo

func NewShadowRepo(in any) shadow.Repo

func ToShadowDo

func ToShadowDo(in *DiDeviceShadow) *shadow.Info

func ToShadowsDo

func ToShadowsDo(in []*DiDeviceShadow) []*shadow.Info

Types

type DiDeviceShadow

type DiDeviceShadow struct {
	ID                int64      `gorm:"column:id;type:BIGINT;primary_key;AUTO_INCREMENT"`
	ProductID         string     `gorm:"column:product_id;uniqueIndex:pi_dn_di;type:CHAR(11);NOT NULL"`
	DeviceName        string     `gorm:"column:device_name;uniqueIndex:pi_dn_di;type:VARCHAR(100);NOT NULL"`
	DataID            string     `gorm:"column:data_id;uniqueIndex:pi_dn_di;type:VARCHAR(100);NOT NULL"`
	Value             string     `gorm:"column:value;type:VARCHAR(100);default:NULL"`
	UpdatedDeviceTime *time.Time `gorm:"column:updated_device_time;default:NULL"`
	stores.Time
}

设备影子表

func ToShadowPo

func ToShadowPo(info *shadow.Info) *DiDeviceShadow

func (*DiDeviceShadow) TableName

func (m *DiDeviceShadow) TableName() string

type ShadowRepo

type ShadowRepo struct {
	// contains filtered or unexported fields
}

func (*ShadowRepo) FindByFilter

func (p *ShadowRepo) FindByFilter(ctx context.Context, f shadow.Filter) ([]*shadow.Info, error)

func (*ShadowRepo) MultiDelete

func (p *ShadowRepo) MultiDelete(ctx context.Context, f shadow.Filter) error

func (*ShadowRepo) MultiUpdate

func (p *ShadowRepo) MultiUpdate(ctx context.Context, data []*shadow.Info) error