promclient

package
v0.0.58 Latest Latest
Warning

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

 Go to latest Published: Mar 6, 2020 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FilterMatchers 

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

FilterMatchers applies the matchers to the given labelset to determine if there is a match and to return all remaining matchers to be matched

func MergeLabelSets 

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

MergeLabelSets merges the labelset b into a

func MergeLabelValues 

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

MergeLabelValues merges the labels from b into a

func NormalizePromError 

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 

type API interface {
	// LabelNames returns all the unique label names present in the block in sorted order.
	LabelNames(ctx context.Context) ([]string, api.Warnings, error)
	// LabelValues performs a query for the values of the given label.
	LabelValues(ctx context.Context, label string) (model.LabelValues, api.Warnings, error)
	// Query performs a query for the given time.
	Query(ctx context.Context, query string, ts time.Time) (model.Value, api.Warnings, error)
	// QueryRange performs a query for the given range.
	QueryRange(ctx context.Context, query string, r v1.Range) (model.Value, api.Warnings, error)
	// Series finds series by label matchers.
	Series(ctx context.Context, matches []string, startTime time.Time, endTime time.Time) ([]model.LabelSet, api.Warnings, 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, api.Warnings, error)
}

API Subset of the interface defined in the prometheus client

type APILabels 

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 AbsoluteTimeFilter 

type AbsoluteTimeFilter struct {
	API
	Start, End time.Time
}

AbsoluteTimeFilter will filter queries out (return nil,nil) for all queries outside the given times

func (*AbsoluteTimeFilter) GetValue 

func (tf *AbsoluteTimeFilter) GetValue(ctx context.Context, start, end time.Time, matchers []*labels.Matcher) (model.Value, api.Warnings, error)

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

func (*AbsoluteTimeFilter) Query 

func (tf *AbsoluteTimeFilter) Query(ctx context.Context, query string, ts time.Time) (model.Value, api.Warnings, error)

Query performs a query for the given time.

func (*AbsoluteTimeFilter) QueryRange 

func (tf *AbsoluteTimeFilter) QueryRange(ctx context.Context, query string, r v1.Range) (model.Value, api.Warnings, error)

QueryRange performs a query for the given range.

func (*AbsoluteTimeFilter) Series 

func (tf *AbsoluteTimeFilter) Series(ctx context.Context, matches []string, startTime time.Time, endTime time.Time) ([]model.LabelSet, api.Warnings, error)

Series finds series by label matchers.

type AddLabelClient 

type AddLabelClient struct {
	API
	Labels model.LabelSet
}

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

func (*AddLabelClient) GetValue 

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

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

func (*AddLabelClient) Key 

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

Key defines the labelset which identifies this client

func (*AddLabelClient) LabelNames added in v0.0.41 

func (c *AddLabelClient) LabelNames(ctx context.Context) ([]string, api.Warnings, error)

LabelNames returns all the unique label names present in the block in sorted order.

func (*AddLabelClient) LabelValues 

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

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

func (*AddLabelClient) Query 

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

Query performs a query for the given time.

func (*AddLabelClient) QueryRange 

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

QueryRange performs a query for the given range.

func (*AddLabelClient) Series 

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

Series finds series by label matchers.

type ClientArgsWrap added in v0.0.49 

type ClientArgsWrap struct {
	api.Client
	// contains filtered or unexported fields
}

ClientArgsWrap wraps the prom API client to add query params to any given urls

func NewClientArgsWrap added in v0.0.49 

func NewClientArgsWrap(api api.Client, args map[string]string) *ClientArgsWrap

NewClientArgsWrap returns a client that will add the given args

func (*ClientArgsWrap) URL added in v0.0.49 

func (c *ClientArgsWrap) URL(ep string, args map[string]string) *url.URL

type DebugAPI 

type DebugAPI struct {
	API
	PrefixMessage string
}

DebugAPI simply logs debug lines for the given API with the given prefix

func (*DebugAPI) GetValue 

func (d *DebugAPI) GetValue(ctx context.Context, start, end time.Time, matchers []*labels.Matcher) (model.Value, api.Warnings, error)

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

func (*DebugAPI) LabelNames added in v0.0.44 

func (d *DebugAPI) LabelNames(ctx context.Context) ([]string, api.Warnings, error)

LabelNames returns all the unique label names present in the block in sorted order.

func (*DebugAPI) LabelValues 

func (d *DebugAPI) LabelValues(ctx context.Context, label string) (model.LabelValues, api.Warnings, error)

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

func (*DebugAPI) Query 

func (d *DebugAPI) Query(ctx context.Context, query string, ts time.Time) (model.Value, api.Warnings, error)

Query performs a query for the given time.

func (*DebugAPI) QueryRange 

func (d *DebugAPI) QueryRange(ctx context.Context, query string, r v1.Range) (model.Value, api.Warnings, error)

QueryRange performs a query for the given range.

func (*DebugAPI) Series 

func (d *DebugAPI) Series(ctx context.Context, matches []string, startTime time.Time, endTime time.Time) ([]model.LabelSet, api.Warnings, error)

Series finds series by label matchers.

type IgnoreErrorAPI 

type IgnoreErrorAPI struct {
	API
}

IgnoreErrorAPI 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 

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

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

func (*IgnoreErrorAPI) Key 

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

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

func (*IgnoreErrorAPI) LabelValues 

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

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

func (*IgnoreErrorAPI) Query 

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

Query performs a query for the given time.

func (*IgnoreErrorAPI) QueryRange 

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

QueryRange performs a query for the given range.

func (*IgnoreErrorAPI) Series 

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

Series finds series by label matchers.

type LabelFilterVisitor 

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

LabelFilterVisitor implements the promql.Visitor interface to filter selectors based on a labelstet

func (*LabelFilterVisitor) Visit 

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

Visit checks if the given node matches the labels in the filter

type MultiAPI 

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

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

func NewMultiAPI 

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

NewMultiAPI returns a MultiAPI

func (*MultiAPI) GetValue 

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

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

func (*MultiAPI) LabelNames 

func (m *MultiAPI) LabelNames(ctx context.Context) ([]string, api.Warnings, error)

LabelNames returns all the unique label names present in the block in sorted order.

func (*MultiAPI) LabelValues 

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

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

func (*MultiAPI) Query 

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

Query performs a query for the given time.

func (*MultiAPI) QueryRange 

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

QueryRange performs a query for the given range.

func (*MultiAPI) Series 

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

Series finds series by label matchers.

type MultiAPIMetricFunc 

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 

type PromAPIRemoteRead struct {
	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 

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

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

type PromAPIV1 

type PromAPIV1 struct {
	v1.API
}

PromAPIV1 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 

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

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

type RelativeTimeFilter 

type RelativeTimeFilter struct {
	API
	Start, End *time.Duration
}

RelativeTimeFilter will filter queries out (return nil,nil) for all queries outside the given durations relative to time.Now()

func (*RelativeTimeFilter) GetValue 

func (tf *RelativeTimeFilter) GetValue(ctx context.Context, start, end time.Time, matchers []*labels.Matcher) (model.Value, api.Warnings, error)

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

func (*RelativeTimeFilter) Query 

func (tf *RelativeTimeFilter) Query(ctx context.Context, query string, ts time.Time) (model.Value, api.Warnings, error)

Query performs a query for the given time.

func (*RelativeTimeFilter) QueryRange 

func (tf *RelativeTimeFilter) QueryRange(ctx context.Context, query string, r v1.Range) (model.Value, api.Warnings, error)

QueryRange performs a query for the given range.

func (*RelativeTimeFilter) Series 

func (tf *RelativeTimeFilter) Series(ctx context.Context, matches []string, startTime time.Time, endTime time.Time) ([]model.LabelSet, api.Warnings, error)

Series finds series by label matchers.

type SeriesIterator 

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

SeriesIterator implements the prometheus SeriesIterator interface

func IteratorsForValue 

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

IteratorsForValue returns SeriesIterators for the value passed in

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 

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

At returns the current timestamp/value pair.

func (*SeriesIterator) Err 

func (s *SeriesIterator) Err() error

Err returns the current error.

func (*SeriesIterator) Labels 

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

Labels returns the labels of the series that the iterator corresponds to.

func (*SeriesIterator) Next 

func (s *SeriesIterator) Next() bool

Next advances the iterator by one.

func (*SeriesIterator) Seek 

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

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

type TimeTruncate added in v0.0.49 

type TimeTruncate struct {
	API
}

TimeTruncate is a workaround to https://github.com/jacksontj/promxy/issues/212 context: https://github.com/prometheus/prometheus/issues/5972 For now we need to truncate the time so that prometheus doesn't round up and return no data <= the timestamp we requested

func NewTimeTruncate added in v0.0.49 

func NewTimeTruncate(a API) *TimeTruncate

func (*TimeTruncate) GetValue added in v0.0.49 

func (t *TimeTruncate) GetValue(ctx context.Context, start, end time.Time, matchers []*labels.Matcher) (model.Value, api.Warnings, error)

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

func (*TimeTruncate) Query added in v0.0.49 

func (t *TimeTruncate) Query(ctx context.Context, query string, ts time.Time) (model.Value, api.Warnings, error)

Query performs a query for the given time.

func (*TimeTruncate) QueryRange added in v0.0.49 

func (t *TimeTruncate) QueryRange(ctx context.Context, query string, r v1.Range) (model.Value, api.Warnings, error)

QueryRange performs a query for the given range.

func (*TimeTruncate) Series added in v0.0.49 

func (t *TimeTruncate) Series(ctx context.Context, matches []string, startTime time.Time, endTime time.Time) ([]model.LabelSet, api.Warnings, error)

Series finds series by label matchers.

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.