sendLogRepo

Documentation

Index

• func ToDeviceLog(db map[string]any) *deviceLog.Send
• type SendLogRepo
  • func NewSendLogRepo(dataSource conf.TSDB) *SendLogRepo
  • func (s *SendLogRepo) DeleteDevice(ctx context.Context, productID string, deviceName string) error
  • func (s *SendLogRepo) DeleteProduct(ctx context.Context, productID string) error
  • func (s *SendLogRepo) GetCountLog(ctx context.Context, filter deviceLog.SendFilter, page def.PageInfo2) (int64, error)
  • func (s *SendLogRepo) GetDeviceLog(ctx context.Context, filter deviceLog.SendFilter, page def.PageInfo2) ([]*deviceLog.Send, error)
  • func (s *SendLogRepo) GetLogStableName() string
  • func (s *SendLogRepo) GetLogTableName(productID, deviceName string) string
  • func (s *SendLogRepo) InitDevice(ctx context.Context, device devices.Info) error
  • func (s *SendLogRepo) InitProduct(ctx context.Context, productID string) (err error)
  • func (s *SendLogRepo) Insert(ctx context.Context, data *deviceLog.Send) error

Functions

func ToDeviceLog

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

Types

type SendLogRepo

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

func NewSendLogRepo

func NewSendLogRepo(dataSource conf.TSDB) *SendLogRepo

func (*SendLogRepo) DeleteDevice

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

func (*SendLogRepo) DeleteProduct

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

func (*SendLogRepo) GetCountLog

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

func (*SendLogRepo) GetDeviceLog

func (s *SendLogRepo) GetDeviceLog(ctx context.Context, filter deviceLog.SendFilter, page def.PageInfo2) (
	[]*deviceLog.Send, error)

func (*SendLogRepo) GetLogStableName

func (s *SendLogRepo) GetLogStableName() string

func (*SendLogRepo) GetLogTableName

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

func (*SendLogRepo) InitDevice

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

func (*SendLogRepo) InitProduct

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

func (*SendLogRepo) Insert

func (s *SendLogRepo) Insert(ctx context.Context, data *deviceLog.Send) error