tsdb

Documentation

Index

• type ErrorResp
  • func (this ErrorResp) String() string
• type InnerError
• type KairosDbClient
  • func NewKairosDbClient(addr string) (*KairosDbClient, error)
  • func (k *KairosDbClient) Query(start, end, rawTags, aggregator, metric string, isRelative bool) (results []Result, err error)
• type OpenTsdbClient
  • func NewOpenTsdbClient(addr string, timeout time.Duration) (*OpenTsdbClient, error)
  • func (c *OpenTsdbClient) Close() error
  • func (c *OpenTsdbClient) Query(start, end, rawTags, aggregator, metric string, isRelative bool) ([]Result, error)
• type Query
• type QueryParams
• type Result
• type TsdbClient

Types

type ErrorResp

type ErrorResp struct {
	Error InnerError `json:"error"`
}

func (ErrorResp) String

func (this ErrorResp) String() string

type InnerError

type InnerError struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
	Details string `json:"details"`
}

type KairosDbClient

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

func NewKairosDbClient

func NewKairosDbClient(addr string) (*KairosDbClient, error)

func (*KairosDbClient) Query

func (k *KairosDbClient) Query(start, end, rawTags, aggregator, metric string, isRelative bool) (results []Result, err error)

type OpenTsdbClient

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

func NewOpenTsdbClient

func NewOpenTsdbClient(addr string, timeout time.Duration) (*OpenTsdbClient, error)

func (*OpenTsdbClient) Close

func (c *OpenTsdbClient) Close() error

func (*OpenTsdbClient) Query

func (c *OpenTsdbClient) Query(start, end, rawTags, aggregator, metric string, isRelative bool) ([]Result, error)

type Query

type Query struct {
	Aggregator string            `json:"aggregator"`
	Metric     string            `json:"metric"`
	Rate       bool              `json:"rate,omitempty"`
	Tags       map[string]string `json:"tags,omitempty"`
}

type QueryParams

type QueryParams struct {
	Start             interface{} `json:"start"`
	End               interface{} `json:"end,omitempty"`
	Queries           []Query     `json:"queries,omitempty"`
	NoAnnotations     bool        `json:"no_annotations,omitempty"`
	GlobalAnnotations bool        `json:"global_annotations,omitempty"`
	MsResolution      bool        `json:"ms,omitempty"`
	ShowTSUIDs        bool        `json:"show_tsuids,omitempty"`
	ShowSummary       bool        `json:"show_summary,omitempty"`
	ShowQuery         bool        `json:"show_query,omitempty"`
	Delete            bool        `json:"delete,omitempty"`
}

type Result

type Result struct {
	Metric        string             `json:"metric"`
	Tags          map[string]string  `json:"tags"`
	AggregateTags []string           `json:"aggregateTags"`
	Dps           map[string]float64 `json:"dps"`
}

type TsdbClient

type TsdbClient interface {
	Query(start, end, rawTags, aggregator, metric string, is_relative bool) ([]Result, error)
}