promclient

package
v0.0.34 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 1, 2019 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FilterMatchers added in v0.0.33 

func FilterMatchers(ls model.LabelSet, matchers []*labels.Matcher) ([]*labels.Matcher, bool)

func MergeLabelSets added in v0.0.31 

func MergeLabelSets(a, b []model.LabelSet) []model.LabelSet

func MergeLabelValues added in v0.0.18 

func MergeLabelValues(a, b []model.LabelValue) []model.LabelValue

func NormalizePromError added in v0.0.31 

func NormalizePromError(err error) error

NormalizePromError converts the errors that the prometheus API client returns into errors that the prometheus API server actually handles and returns proper error codes for

Types

type API added in v0.0.31 

type API interface {
	// LabelValues performs a query for the values of the given label.
	LabelValues(ctx context.Context, label string) (model.LabelValues, error)
	// Query performs a query for the given time.
	Query(ctx context.Context, query string, ts time.Time) (model.Value, error)
	// QueryRange performs a query for the given range.
	QueryRange(ctx context.Context, query string, r v1.Range) (model.Value, error)
	// Series finds series by label matchers.
	Series(ctx context.Context, matches []string, startTime time.Time, endTime time.Time) ([]model.LabelSet, error)
	// GetValue loads the raw data for a given set of matchers in the time range
	GetValue(ctx context.Context, start, end time.Time, matchers []*labels.Matcher) (model.Value, error)
}

API Subset of the interface defined in the prometheus client

type APILabels added in v0.0.34 

type APILabels interface {
	API
	// Key returns a labelset used to determine other api clients that are the "same"
	Key() model.LabelSet
}

APILabels includes a Key() mechanism to differentiate which APIs are "the same"

type AddLabelClient added in v0.0.33 

type AddLabelClient struct {
	API
	Labels model.LabelSet
}

AddLabelClient proxies a client and adds the given labels to all results

func (*AddLabelClient) GetValue added in v0.0.33 

func (c *AddLabelClient) GetValue(ctx context.Context, start, end time.Time, matchers []*labels.Matcher) (model.Value, error)

GetValue loads the raw data for a given set of matchers in the time range

func (*AddLabelClient) Key added in v0.0.34 

func (c *AddLabelClient) Key() model.LabelSet

func (*AddLabelClient) LabelValues added in v0.0.33 

func (c *AddLabelClient) LabelValues(ctx context.Context, label string) (model.LabelValues, error)

LabelValues performs a query for the values of the given label.

func (*AddLabelClient) Query added in v0.0.33 

func (c *AddLabelClient) Query(ctx context.Context, query string, ts time.Time) (model.Value, error)

Query performs a query for the given time.

func (*AddLabelClient) QueryRange added in v0.0.33 

func (c *AddLabelClient) QueryRange(ctx context.Context, query string, r v1.Range) (model.Value, error)

QueryRange performs a query for the given range.

func (*AddLabelClient) Series added in v0.0.33 

func (c *AddLabelClient) Series(ctx context.Context, matches []string, startTime time.Time, endTime time.Time) ([]model.LabelSet, error)

Series finds series by label matchers.

type DataResult 

type DataResult struct {
	Status    promhttputil.Status    `json:"status"`
	Data      promhttputil.QueryData `json:"data"`
	ErrorType promhttputil.ErrorType `json:"errorType,omitempty"`
	Error     string                 `json:"error,omitempty"`
}

func (*DataResult) UnmarshalEasyJSON 

func (out *DataResult) UnmarshalEasyJSON(in *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*DataResult) UnmarshalJSON 

func (v *DataResult) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

type IgnoreErrorAPI added in v0.0.34 

type IgnoreErrorAPI struct {
	API
}

OptionalAPI simply swallows all errors from the given API. This allows the API to be used with all the regular error merging logic and effectively have its errors not considered

func (*IgnoreErrorAPI) GetValue added in v0.0.34 

func (n *IgnoreErrorAPI) GetValue(ctx context.Context, start, end time.Time, matchers []*labels.Matcher) (model.Value, error)

GetValue loads the raw data for a given set of matchers in the time range

func (*IgnoreErrorAPI) Key added in v0.0.34 

func (n *IgnoreErrorAPI) Key() model.LabelSet

Key returns a labelset used to determine other api clients that are the "same"

func (*IgnoreErrorAPI) LabelValues added in v0.0.34 

func (n *IgnoreErrorAPI) LabelValues(ctx context.Context, label string) (model.LabelValues, error)

LabelValues performs a query for the values of the given label.

func (*IgnoreErrorAPI) Query added in v0.0.34 

func (n *IgnoreErrorAPI) Query(ctx context.Context, query string, ts time.Time) (model.Value, error)

Query performs a query for the given time.

func (*IgnoreErrorAPI) QueryRange added in v0.0.34 

func (n *IgnoreErrorAPI) QueryRange(ctx context.Context, query string, r v1.Range) (model.Value, error)

QueryRange performs a query for the given range.

func (*IgnoreErrorAPI) Series added in v0.0.34 

func (n *IgnoreErrorAPI) Series(ctx context.Context, matches []string, startTime time.Time, endTime time.Time) ([]model.LabelSet, error)

Series finds series by label matchers.

type LabelFilterVisitor added in v0.0.33 

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

func (*LabelFilterVisitor) Visit added in v0.0.33 

func (l *LabelFilterVisitor) Visit(node promql.Node, path []promql.Node) (w promql.Visitor, err error)

type MultiAPI added in v0.0.31 

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

MultiAPI implements the API interface while merging the results from the apis it wraps

func NewMultiAPI added in v0.0.31 

func NewMultiAPI(apis []API, antiAffinity model.Time, metricFunc MultiAPIMetricFunc, requiredCount int) *MultiAPI

NewMultiAPI returns a MultiAPI

func (*MultiAPI) GetValue added in v0.0.32 

func (m *MultiAPI) GetValue(ctx context.Context, start, end time.Time, matchers []*labels.Matcher) (model.Value, error)

GetValue fetches a `model.Value` which represents the actual collected data

func (*MultiAPI) LabelValues added in v0.0.31 

func (m *MultiAPI) LabelValues(ctx context.Context, label string) (model.LabelValues, error)

LabelValues performs a query for the values of the given label.

func (*MultiAPI) Query added in v0.0.31 

func (m *MultiAPI) Query(ctx context.Context, query string, ts time.Time) (model.Value, error)

Query performs a query for the given time.

func (*MultiAPI) QueryRange added in v0.0.31 

func (m *MultiAPI) QueryRange(ctx context.Context, query string, r v1.Range) (model.Value, error)

QueryRange performs a query for the given range.

func (*MultiAPI) Series added in v0.0.31 

func (m *MultiAPI) Series(ctx context.Context, matches []string, startTime time.Time, endTime time.Time) ([]model.LabelSet, error)

Series finds series by label matchers.

type MultiAPIMetricFunc added in v0.0.31 

type MultiAPIMetricFunc func(i int, api, status string, took float64)

MultiAPIMetricFunc defines a method where a client can record metrics about the specific API calls made through this multi client

type PromAPIRemoteRead added in v0.0.32 

type PromAPIRemoteRead struct {
	v1.API
	*remote.Client
}

PromAPIRemoteRead implements our internal API interface using a combination of the v1 HTTP API and the "experimental" remote_read API

func (*PromAPIRemoteRead) GetValue added in v0.0.32 

func (p *PromAPIRemoteRead) GetValue(ctx context.Context, start, end time.Time, matchers []*labels.Matcher) (model.Value, error)

type PromAPIV1 added in v0.0.32 

type PromAPIV1 struct {
	v1.API
}

PromAPI implements our internal API interface using *only* the v1 HTTP API Simply wraps the prom API to fullfil our internal API interface

func (*PromAPIV1) GetValue added in v0.0.32 

func (p *PromAPIV1) GetValue(ctx context.Context, start, end time.Time, matchers []*labels.Matcher) (model.Value, error)

GetValue loads the raw data for a given set of matchers in the time range

type SeriesIterator 

type SeriesIterator struct {
	V interface{}
	// contains filtered or unexported fields
}

func IteratorsForValue 

func IteratorsForValue(v model.Value) []*SeriesIterator

func NewSeriesIterator 

func NewSeriesIterator(v interface{}) *SeriesIterator

NewSeriesIterator return a series iterator for the given value TODO: error return if the type is incorrect?

func (*SeriesIterator) At added in v0.0.2 

func (s *SeriesIterator) At() (t int64, v float64)

At returns the current timestamp/value pair.

func (*SeriesIterator) Err added in v0.0.2 

func (s *SeriesIterator) Err() error

Err returns the current error.

func (*SeriesIterator) Labels added in v0.0.2 

func (s *SeriesIterator) Labels() labels.Labels

Returns the metric of the series that the iterator corresponds to.

func (*SeriesIterator) Next added in v0.0.2 

func (s *SeriesIterator) Next() bool

Next advances the iterator by one.

func (*SeriesIterator) Seek added in v0.0.2 

func (s *SeriesIterator) Seek(t int64) bool

Seek advances the iterator forward to the value at or after the given timestamp.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.