datasource

Documentation

Index

• func InitSecretFlags()
• type Label
• type Metric
  • func (m *Metric) AddLabel(key, value string)
  • func (m *Metric) Label(key string) string
  • func (m *Metric) SetLabel(key, value string)
  • func (m *Metric) SetLabels(ls map[string]string)
• type Param
• type Querier
• type QuerierBuilder
  • func Init(extraParams url.Values) (QuerierBuilder, error)
• type QuerierParams
• type VMStorage
  • func NewVMStorage(baseURL string, authCfg *promauth.Config, lookBack time.Duration, ...) *VMStorage
  • func (s *VMStorage) ApplyParams(params QuerierParams) *VMStorage
  • func (s *VMStorage) BuildWithParams(params QuerierParams) Querier
  • func (s *VMStorage) Clone() *VMStorage
  • func (s *VMStorage) Query(ctx context.Context, query string, ts time.Time) ([]Metric, *http.Request, error)
  • func (s *VMStorage) QueryRange(ctx context.Context, query string, start, end time.Time) ([]Metric, error)

Functions

func InitSecretFlags

func InitSecretFlags()

InitSecretFlags must be called after flag.Parse and before any logging

Types

type Label

type Label struct {
	Name  string
	Value string
}

Label represents metric's label

type Metric

type Metric struct {
	Labels     []Label
	Timestamps []int64
	Values     []float64
}

Metric is the basic entity which should be return by datasource

func (*Metric) AddLabel

func (m *Metric) AddLabel(key, value string)

AddLabel appends the given label to the label set

func (*Metric) Label

func (m *Metric) Label(key string) string

Label returns the given label value. If label is missing empty string will be returned

func (*Metric) SetLabel

func (m *Metric) SetLabel(key, value string)

SetLabel adds or updates existing one label by the given key and label

func (*Metric) SetLabels

func (m *Metric) SetLabels(ls map[string]string)

SetLabels sets the given map as Metric labels

type Param

type Param struct {
	Key, Value string
}

Param represents an HTTP GET param

type Querier

type Querier interface {
	// Query executes instant request with the given query at the given ts.
	// It returns list of Metric in response, the http.Request used for sending query
	// and error if any. Returned http.Request can't be reused and its body is already read.
	// Query should stop once ctx is cancelled.
	Query(ctx context.Context, query string, ts time.Time) ([]Metric, *http.Request, error)
	// QueryRange executes range request with the given query on the given time range.
	// It returns list of Metric in response and error if any.
	// QueryRange should stop once ctx is cancelled.
	QueryRange(ctx context.Context, query string, from, to time.Time) ([]Metric, error)
}

Querier interface wraps Query and QueryRange methods

type QuerierBuilder

type QuerierBuilder interface {
	// BuildWithParams creates a new Querier object with the given params
	BuildWithParams(params QuerierParams) Querier
}

QuerierBuilder builds Querier with given params.

func Init

func Init(extraParams url.Values) (QuerierBuilder, error)

Init creates a Querier from provided flag values. Provided extraParams will be added as GET params for each request.

type QuerierParams

type QuerierParams struct {
	DataSourceType     string
	EvaluationInterval time.Duration
	QueryParams        url.Values
	Headers            map[string]string
	Debug              bool
}

QuerierParams params for Querier.

type VMStorage

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

VMStorage represents vmstorage entity with ability to read and write metrics

func NewVMStorage

func NewVMStorage(baseURL string, authCfg *promauth.Config, lookBack time.Duration, queryStep time.Duration, appendTypePrefix bool, c *http.Client) *VMStorage

NewVMStorage is a constructor for VMStorage

func (*VMStorage) ApplyParams

func (s *VMStorage) ApplyParams(params QuerierParams) *VMStorage

ApplyParams - changes given querier params.

func (*VMStorage) BuildWithParams

func (s *VMStorage) BuildWithParams(params QuerierParams) Querier

BuildWithParams - implements interface.

func (*VMStorage) Clone

func (s *VMStorage) Clone() *VMStorage

Clone makes clone of VMStorage, shares http client.

func (*VMStorage) Query

func (s *VMStorage) Query(ctx context.Context, query string, ts time.Time) ([]Metric, *http.Request, error)

Query executes the given query and returns parsed response

func (*VMStorage) QueryRange

func (s *VMStorage) QueryRange(ctx context.Context, query string, start, end time.Time) ([]Metric, error)

QueryRange executes the given query on the given time range. For Prometheus type see https://prometheus.io/docs/prometheus/latest/querying/api/#range-queries Graphite type isn't supported.