Documentation ¶
Index ¶
- func ToDeviceLog(productID string, db map[string]any) *deviceLog.Hub
- type HubLogRepo
- func (h *HubLogRepo) DeleteDevice(ctx context.Context, productID string, deviceName string) error
- func (h *HubLogRepo) DeleteProduct(ctx context.Context, productID string) error
- func (h *HubLogRepo) GetCountLog(ctx context.Context, filter deviceLog.HubFilter, page def.PageInfo2) (int64, error)
- func (h *HubLogRepo) GetDeviceLog(ctx context.Context, filter deviceLog.HubFilter, page def.PageInfo2) ([]*deviceLog.Hub, error)
- func (h *HubLogRepo) GetLogStableName() string
- func (h *HubLogRepo) GetLogTableName(productID, deviceName string) string
- func (h *HubLogRepo) InitDevice(ctx context.Context, device devices.Info) error
- func (h *HubLogRepo) InitProduct(ctx context.Context, productID string) (err error)
- func (h *HubLogRepo) Insert(ctx context.Context, data *deviceLog.Hub) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type HubLogRepo ¶
type HubLogRepo struct {
// contains filtered or unexported fields
}
func NewHubLogRepo ¶
func NewHubLogRepo(dataSource conf.TSDB) *HubLogRepo
func (*HubLogRepo) DeleteDevice ¶
func (*HubLogRepo) DeleteProduct ¶
func (h *HubLogRepo) DeleteProduct(ctx context.Context, productID string) error
func (*HubLogRepo) GetCountLog ¶
func (*HubLogRepo) GetDeviceLog ¶
func (*HubLogRepo) GetLogStableName ¶
func (h *HubLogRepo) GetLogStableName() string
func (*HubLogRepo) GetLogTableName ¶
func (h *HubLogRepo) GetLogTableName(productID, deviceName string) string
func (*HubLogRepo) InitDevice ¶
func (*HubLogRepo) InitProduct ¶
func (h *HubLogRepo) InitProduct(ctx context.Context, productID string) (err error)
Click to show internal directories.
Click to hide internal directories.