abnormalLogRepo

Documentation

Index

• func ToDeviceLog(db map[string]any) *deviceLog.Abnormal
• type AbnormalLogRepo
  • func NewAbnormalLogRepo(dataSource conf.TSDB) *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) GetLogStableName() string
  • func (s *AbnormalLogRepo) GetLogTableName(productID, deviceName string) string
  • 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

Functions

func ToDeviceLog

func ToDeviceLog(db map[string]any) *deviceLog.Abnormal

Types

type AbnormalLogRepo

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

func NewAbnormalLogRepo

func NewAbnormalLogRepo(dataSource conf.TSDB) *AbnormalLogRepo

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) GetLogStableName

func (s *AbnormalLogRepo) GetLogStableName() string

func (*AbnormalLogRepo) GetLogTableName

func (s *AbnormalLogRepo) GetLogTableName(productID, deviceName string) string

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