abnormalLogRepo

Documentation

Index

• func NewAbnormalLogRepo(dataSource conf.TSDB) deviceLog.AbnormalRepo
• type Abnormal
  • func (m *Abnormal) TableName() string
• type AbnormalLogRepo
  • func (s *AbnormalLogRepo) DeleteDevice(ctx context.Context, productID string, deviceName string) error
  • func (s *AbnormalLogRepo) DeleteProduct(ctx context.Context, productID string) error
  • func (s *AbnormalLogRepo) GetCountLog(ctx context.Context, filter deviceLog.AbnormalFilter, page def.PageInfo2) (int64, error)
  • func (s *AbnormalLogRepo) GetDeviceLog(ctx context.Context, filter deviceLog.AbnormalFilter, page def.PageInfo2) ([]*deviceLog.Abnormal, error)
  • func (s *AbnormalLogRepo) InitDevice(ctx context.Context, device devices.Info) error
  • func (s *AbnormalLogRepo) InitProduct(ctx context.Context, productID string) (err error)
  • func (s *AbnormalLogRepo) Insert(ctx context.Context, data *deviceLog.Abnormal) error
  • func (s *AbnormalLogRepo) UpdateDevice(ctx context.Context, devices []*devices.Core, affiliation devices.Affiliation) error
  • func (s *AbnormalLogRepo) UpdateDevices(ctx context.Context, devices []*devices.Info) error
  • func (s *AbnormalLogRepo) VersionUpdate(ctx context.Context, version string) error

Functions

func NewAbnormalLogRepo

func NewAbnormalLogRepo(dataSource conf.TSDB) deviceLog.AbnormalRepo

Types

type Abnormal

type Abnormal struct {
	*deviceLog.Abnormal
}

func (*Abnormal) TableName

func (m *Abnormal) TableName() string

type AbnormalLogRepo

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

func (*AbnormalLogRepo) DeleteDevice

func (s *AbnormalLogRepo) DeleteDevice(ctx context.Context, productID string, deviceName string) error

func (*AbnormalLogRepo) DeleteProduct

func (s *AbnormalLogRepo) DeleteProduct(ctx context.Context, productID string) error

func (*AbnormalLogRepo) GetCountLog

func (s *AbnormalLogRepo) GetCountLog(ctx context.Context, filter deviceLog.AbnormalFilter, page def.PageInfo2) (int64, error)

func (*AbnormalLogRepo) GetDeviceLog

func (s *AbnormalLogRepo) GetDeviceLog(ctx context.Context, filter deviceLog.AbnormalFilter, page def.PageInfo2) (
	[]*deviceLog.Abnormal, error)

func (*AbnormalLogRepo) InitDevice

func (s *AbnormalLogRepo) InitDevice(ctx context.Context, device devices.Info) error

func (*AbnormalLogRepo) InitProduct

func (s *AbnormalLogRepo) InitProduct(ctx context.Context, productID string) (err error)

func (*AbnormalLogRepo) Insert

func (s *AbnormalLogRepo) Insert(ctx context.Context, data *deviceLog.Abnormal) error

func (*AbnormalLogRepo) UpdateDevice

func (s *AbnormalLogRepo) UpdateDevice(ctx context.Context, devices []*devices.Core, affiliation devices.Affiliation) error

func (*AbnormalLogRepo) UpdateDevices

func (s *AbnormalLogRepo) UpdateDevices(ctx context.Context, devices []*devices.Info) error

func (*AbnormalLogRepo) VersionUpdate

func (s *AbnormalLogRepo) VersionUpdate(ctx context.Context, version string) error