victoriametrics

Documentation

Index

• Constants
• func NewVMAdapter(datasource *tsdb.DataSource) (tsdb.TsdbQueryEndpoint, error)
• type Client
  • func NewClient(endpoint string) (Client, error)
• type Response
• type ResponseData
• type ResponseDataResult
• type ResponseDataResultValue
• type ResponseStats
• type TimeRange
  • func NewTimeRange(start, end int64) *TimeRange
  • func NewTimeRangeByInfluxTimeRange(tr *influxql.TimeRange) *TimeRange

Constants

const (
	ErrVMInvalidResponse = errors.Error("VictoriaMetrics invalid response")
)

Functions

func NewVMAdapter

func NewVMAdapter(datasource *tsdb.DataSource) (tsdb.TsdbQueryEndpoint, error)

Types

type Client

type Client interface {
	QueryRange(ctx context.Context, httpCli *http.Client, query string, step time.Duration, timeRange *TimeRange, disableCache bool) (*Response, error)
}

func NewClient

func NewClient(endpoint string) (Client, error)

type Response

type Response struct {
	Status string `json:"status"`
	Data   ResponseData
	Stats  ResponseStats
}

type ResponseData

type ResponseData struct {
	ResultType string               `json:"resultType"`
	Result     []ResponseDataResult `json:"result"`
}

type ResponseDataResult

type ResponseDataResult struct {
	Metric map[string]string         `json:"metric"`
	Values []ResponseDataResultValue `json:"values"`
}

type ResponseDataResultValue

type ResponseDataResultValue []interface{}

ResponseDataResultValue likes: [ 1652169600, "1" ]

type ResponseStats

type ResponseStats struct {
	// SeriesFetched is like integer type: {seriesFetched: "2"}
	SeriesFetched string `json:"seriesFetched"`
}

type TimeRange

type TimeRange struct {
	Start int64
	End   int64
}

func NewTimeRange

func NewTimeRange(start, end int64) *TimeRange

func NewTimeRangeByInfluxTimeRange

func NewTimeRangeByInfluxTimeRange(tr *influxql.TimeRange) *TimeRange