query

Documentation

Index

• Variables
• func Init(cfg SeriesQuerySection)
• func NewQueryRequest(endpoint, metric string, tagsMap map[string]string, start, end int64) (*dataobj.QueryData, error)
• func Query(reqs []*dataobj.QueryData) ([]*dataobj.TsdbQueryResponse, error)
• type ConnPools
  • func CreateConnPools(maxConns, maxIdle, connTimeout, callTimeout int, cluster []string) *ConnPools
  • func (this *ConnPools) Call(method string, args interface{}, resp interface{}) error
  • func (this *ConnPools) Get() *pool.ConnPool
• type Counter
• type IndexData
  • func Xclude(request *IndexReq) ([]IndexData, error)
• type IndexReq
• type IndexRequest
• type IndexResp
• type RpcClient
  • func (this RpcClient) Call(method string, args interface{}, reply interface{}) error
  • func (this RpcClient) Close() error
  • func (this RpcClient) Closed() bool
  • func (this RpcClient) Name() string
• type SeriesQuerySection
• type XCludeStruct

Variables

var (
	TransferConnPools *ConnPools = &ConnPools{}

	Config SeriesQuerySection
)

var (
	ErrorIndexParamIllegal = errors.New("index param illegal")
	ErrorQueryParamIllegal = errors.New("query param illegal")
)

Functions

func Init

func Init(cfg SeriesQuerySection)

func NewQueryRequest

func NewQueryRequest(endpoint, metric string, tagsMap map[string]string,
	start, end int64) (*dataobj.QueryData, error)

func Query

func Query(reqs []*dataobj.QueryData) ([]*dataobj.TsdbQueryResponse, error)

执行Query操作 默认不重试, 如果要做重试, 在这里完成

Types

type ConnPools

type ConnPools struct {
	sync.RWMutex
	Pools       []*pool.ConnPool
	MaxConns    int
	MaxIdle     int
	ConnTimeout int
	CallTimeout int
}

每个后端backend对应一个ConnPool

func CreateConnPools

func CreateConnPools(maxConns, maxIdle, connTimeout, callTimeout int, cluster []string) *ConnPools

func (*ConnPools) Call

func (this *ConnPools) Call(method string, args interface{}, resp interface{}) error

同步发送, 完成发送或超时后 才能返回

func (*ConnPools) Get

func (this *ConnPools) Get() *pool.ConnPool

type Counter

type Counter struct {
	Counter string `json:"counter"`
	Step    int    `json:"step"`
	Dstype  string `json:"dstype`
}

type IndexData

type IndexData struct {
	Endpoint string   `json:"endpoint"`
	Metric   string   `json:"metric"`
	Tags     []string `json:"tags"`
	Step     int      `json:"step"`
	Dstype   string   `json:"dstype"`
}

func Xclude

func Xclude(request *IndexReq) ([]IndexData, error)

index的xclude 不支持批量查询, 暂时不做

type IndexReq

type IndexReq struct {
	Endpoints []string       `json:"endpoints"`
	Metric    string         `json:"metric"`
	Include   []XCludeStruct `json:"include,omitempty"`
	Exclude   []XCludeStruct `json:"exclude,omitempty"`
}

type IndexRequest

type IndexRequest struct {
	Endpoints []string            `json:"endpoints"`
	Metric    string              `json:"metric"`
	Include   map[string][]string `json:"include"`
	Exclude   map[string][]string `json:"exclude"`
}

type IndexResp

type IndexResp struct {
	Data []IndexData `json:"dat"`
	Err  string      `json:"err"`
}

type RpcClient

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

RpcCient, 要实现io.Closer接口

func (RpcClient) Call

func (this RpcClient) Call(method string, args interface{}, reply interface{}) error

func (RpcClient) Close

func (this RpcClient) Close() error

func (RpcClient) Closed

func (this RpcClient) Closed() bool

func (RpcClient) Name

func (this RpcClient) Name() string

type SeriesQuerySection

type SeriesQuerySection struct {
	MaxConn          int    `json:"maxConn"`     //
	MaxIdle          int    `json:"maxIdle"`     //
	ConnTimeout      int    `json:"connTimeout"` // 连接超时
	CallTimeout      int    `json:"callTimeout"` // 请求超时
	IndexPath        string `json:"indexPath"`
	IndexCallTimeout int    `json:"indexCallTimeout"` // 请求超时
}

type XCludeStruct

type XCludeStruct struct {
	Tagk string   `json:"tagk"`
	Tagv []string `json:"tagv"`
}

******** 补全索引相关 ********