tdengine

package
v6.7.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 8, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var TdengineOptions = &TdengineOptionsStruct{Data: make(map[int64]TdengineOption)}

Data key is cluster name

Functions

func ConvertToTStData

func ConvertToTStData(src APIResponse, key Keys, ref string) ([]*models.DataResp, error)

Types

type APIResponse

type APIResponse struct {
	Code       int             `json:"code"`
	ColumnMeta [][]interface{} `json:"column_meta"`
	Data       [][]interface{} `json:"data"`
	Rows       int             `json:"rows"`
}

func TimeFormat

func TimeFormat(src APIResponse, timeFormat string) APIResponse

type Column

type Column struct {
	Name string `json:"name"`
	Type string `json:"type"`
	Size int    `json:"size"`
}

type Keys

type Keys struct {
	LabelKey   string `json:"labelKey"`  // 多个用空格分隔
	MetricKey  string `json:"metricKey"` // 多个用空格分隔
	TimeFormat string `json:"timeFormat"`
}

type TdengineClientMap

type TdengineClientMap struct {
	sync.RWMutex

	ReaderClients map[int64]*tdengineClient
	// contains filtered or unexported fields
}

func NewTdengineClient

func NewTdengineClient(ctx *ctx.Context, heartbeat aconf.HeartbeatConfig) *TdengineClientMap

func (*TdengineClientMap) Del

func (pc *TdengineClientMap) Del(datasourceId int64)

func (*TdengineClientMap) GetCli

func (pc *TdengineClientMap) GetCli(datasourceId int64) *tdengineClient

func (*TdengineClientMap) GetDatasourceIds

func (pc *TdengineClientMap) GetDatasourceIds() []int64

func (*TdengineClientMap) Hit

func (pc *TdengineClientMap) Hit(datasourceIds []int64) []int64

Hit 根据当前有效的 datasourceId 和规则的 datasourceId 配置计算有效的cluster列表

func (*TdengineClientMap) InitReader

func (pc *TdengineClientMap) InitReader() error

func (*TdengineClientMap) IsNil

func (pc *TdengineClientMap) IsNil(datasourceId int64) bool

func (*TdengineClientMap) Reset

func (pc *TdengineClientMap) Reset()

func (*TdengineClientMap) Set

func (pc *TdengineClientMap) Set(datasourceId int64, r *tdengineClient)

type TdengineOption

type TdengineOption struct {
	DatasourceName string
	Url            string
	BasicAuthUser  string
	BasicAuthPass  string
	Token          string

	Timeout     int64
	DialTimeout int64

	MaxIdleConnsPerHost int

	Headers []string

	tlsx.ClientConfig
}

func (*TdengineOption) Equal

func (po *TdengineOption) Equal(target TdengineOption) bool

type TdengineOptionsStruct

type TdengineOptionsStruct struct {
	Data map[int64]TdengineOption
	sync.RWMutex
}

func (*TdengineOptionsStruct) Del

func (pos *TdengineOptionsStruct) Del(datasourceId int64)

func (*TdengineOptionsStruct) Get

func (pos *TdengineOptionsStruct) Get(datasourceId int64) (TdengineOption, bool)

func (*TdengineOptionsStruct) Set

func (pos *TdengineOptionsStruct) Set(datasourceId int64, po TdengineOption)

type TdengineQuery

type TdengineQuery struct {
	From     string `json:"from"`
	Interval int64  `json:"interval"`
	Keys     Keys   `json:"keys"`
	Query    string `json:"query"` // 查询条件
	Ref      string `json:"ref"`   // 变量
	To       string `json:"to"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL