datasource

Documentation

Index

• 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)
• type Querier
  • func Init() (Querier, error)
• type Type
  • func NewGraphiteType() Type
  • func NewPrometheusType() Type
  • func NewRawType(d string) Type
  • func (t *Type) Get() string
  • func (t Type) MarshalYAML() (interface{}, error)
  • func (t *Type) Set(d Type)
  • func (t Type) String() string
  • func (t *Type) UnmarshalYAML(unmarshal func(interface{}) error) error
  • func (t *Type) ValidateExpr(expr string) error
• type VMStorage
  • func NewVMStorage(baseURL, basicAuthUser, basicAuthPass string, lookBack time.Duration, ...) *VMStorage
  • func (s *VMStorage) Query(ctx context.Context, query string, dataSourceType Type) ([]Metric, error)

Types

type Label

type Label struct {
	Name  string
	Value string
}

Label represents metric's label

type Metric

type Metric struct {
	Labels    []Label
	Timestamp int64
	Value     float64
}

Metric is the basic entity which should be return by datasource It represents single data point with full list of labels

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

type Querier

type Querier interface {
	Query(ctx context.Context, query string, engine Type) ([]Metric, error)
}

Querier interface wraps Query method which executes given query and returns list of Metrics as result

func Init

func Init() (Querier, error)

Init creates a Querier from provided flag values.

type Type

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

Type represents data source type

func NewGraphiteType

func NewGraphiteType() Type

NewGraphiteType returns graphite datasource type

func NewPrometheusType

func NewPrometheusType() Type

NewPrometheusType returns prometheus datasource type

func NewRawType

func NewRawType(d string) Type

NewRawType returns datasource type from raw string without validation.

func (*Type) Get

func (t *Type) Get() string

Get returns datasource type

func (Type) MarshalYAML

func (t Type) MarshalYAML() (interface{}, error)

MarshalYAML implements the yaml.Unmarshaler interface.

func (*Type) Set

func (t *Type) Set(d Type)

Set changes datasource type

func (Type) String

func (t Type) String() string

String implements String interface with default value.

func (*Type) UnmarshalYAML

func (t *Type) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements the yaml.Unmarshaler interface.

func (*Type) ValidateExpr

func (t *Type) ValidateExpr(expr string) error

ValidateExpr validates query expression with datasource ql.

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, basicAuthUser, basicAuthPass string, lookBack time.Duration, queryStep time.Duration, appendTypePrefix bool, c *http.Client) *VMStorage

NewVMStorage is a constructor for VMStorage

func (*VMStorage) Query

func (s *VMStorage) Query(ctx context.Context, query string, dataSourceType Type) ([]Metric, error)

Query reads metrics from datasource by given query and type