tdengine

Documentation

Index

• func NewClient(config dtos.Configuration, lc logger.LoggingClient) (c interfaces.DataDBClient, errEdgeX error)
• type Client
  • func (c *Client) AddDatabaseField(ctx context.Context, stableName string, specsType constants.SpecsType, ...) (err error)
  • func (c *Client) CloseSession()
  • func (c *Client) CreateDatabase(ctx context.Context) (err error)
  • func (c *Client) CreateStable(ctx context.Context, product models.Product) (err error)
  • func (c *Client) CreateTable(ctx context.Context, stable, table string) (err error)
  • func (c *Client) DelDatabaseField(ctx context.Context, stableName, code string) (err error)
  • func (s *Client) DropStable(ctx context.Context, table string) (err error)
  • func (s *Client) DropTable(ctx context.Context, table string) (err error)
  • func (c *Client) GetDataDBType() constants.DataType
  • func (c *Client) GetDeviceEvent(req dtos.ThingModelEventDataRequest, device models.Device, ...) ([]dtos.EventData, int, error)
  • func (c *Client) GetDeviceEventCount(req dtos.ThingModelEventDataRequest) (int, error)
  • func (c *Client) GetDeviceMsgCountByGiveTime(deviceId string, startTime, endTime int64) (int, error)
  • func (c *Client) GetDeviceProperty(req dtos.ThingModelPropertyDataRequest, device models.Device) ([]dtos.ReportData, int, error)
  • func (c *Client) GetDevicePropertyCount(request dtos.ThingModelPropertyDataRequest) (int, error)
  • func (c *Client) GetDeviceService(req dtos.ThingModelServiceDataRequest, device models.Device, ...) ([]dtos.SaveServiceIssueData, int, error)
  • func (c *Client) GetOne(ctx context.Context, sql string, args ...any) (rs gdb.Record, err error)
  • func (c *Client) Insert(ctx context.Context, table string, data map[string]interface{}) (err error)
  • func (c *Client) ModifyDatabaseField(ctx context.Context, stableName string, specsType constants.SpecsType, ...) (err error)

Functions

func NewClient

func NewClient(config dtos.Configuration, lc logger.LoggingClient) (c interfaces.DataDBClient, errEdgeX error)

Types

type Client

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

func (*Client) AddDatabaseField

func (c *Client) AddDatabaseField(ctx context.Context, stableName string, specsType constants.SpecsType, code string, name string) (err error)

func (*Client) CloseSession

func (c *Client) CloseSession()

func (*Client) CreateDatabase

func (c *Client) CreateDatabase(ctx context.Context) (err error)

func (*Client) CreateStable

func (c *Client) CreateStable(ctx context.Context, product models.Product) (err error)

func (*Client) CreateTable

func (c *Client) CreateTable(ctx context.Context, stable, table string) (err error)

CreateTable 创建表

func (*Client) DelDatabaseField

func (c *Client) DelDatabaseField(ctx context.Context, stableName, code string) (err error)

func (*Client) DropStable

func (s *Client) DropStable(ctx context.Context, table string) (err error)

func (*Client) DropTable

func (s *Client) DropTable(ctx context.Context, table string) (err error)

DropTable 删除子表

func (*Client) GetDataDBType

func (c *Client) GetDataDBType() constants.DataType

func (*Client) GetDeviceEvent

func (c *Client) GetDeviceEvent(req dtos.ThingModelEventDataRequest, device models.Device, product models.Product) ([]dtos.EventData, int, error)

func (*Client) GetDeviceEventCount

func (c *Client) GetDeviceEventCount(req dtos.ThingModelEventDataRequest) (int, error)

func (*Client) GetDeviceMsgCountByGiveTime

func (c *Client) GetDeviceMsgCountByGiveTime(deviceId string, startTime, endTime int64) (int, error)

func (*Client) GetDeviceProperty

func (c *Client) GetDeviceProperty(req dtos.ThingModelPropertyDataRequest, device models.Device) ([]dtos.ReportData, int, error)

func (*Client) GetDevicePropertyCount

func (c *Client) GetDevicePropertyCount(request dtos.ThingModelPropertyDataRequest) (int, error)

func (*Client) GetDeviceService

func (c *Client) GetDeviceService(req dtos.ThingModelServiceDataRequest, device models.Device, product models.Product) ([]dtos.SaveServiceIssueData, int, error)

func (*Client) GetOne

func (c *Client) GetOne(ctx context.Context, sql string, args ...any) (rs gdb.Record, err error)

func (*Client) Insert

func (c *Client) Insert(ctx context.Context, table string, data map[string]interface{}) (err error)

func (*Client) ModifyDatabaseField

func (c *Client) ModifyDatabaseField(ctx context.Context, stableName string, specsType constants.SpecsType, code string, name string) (err error)