prometheus

Documentation

Index

• func FilterSeriesByOptions(series []*ts.Series, opts *storage.FetchOptions) []*ts.Series
• func ParseRequestTimeout(r *http.Request, configFetchTimeout time.Duration) (time.Duration, error)
• func ParseSeriesMatchQuery(r *http.Request, parseOpts xpromql.ParseOptions, tagOptions models.TagOptions) ([]*storage.FetchQuery, *xhttp.ParseError)
• func RenderListTagResultsJSON(w io.Writer, result *consolidators.CompleteTagsResult) error
• func RenderSeriesMatchResultsJSON(w io.Writer, results []models.Metrics, dropRole bool) error
• func RenderTagCompletionResultsJSON(w io.Writer, result consolidators.CompleteTagsResult) error
• func RenderTagValuesResultsJSON(w io.Writer, result *consolidators.CompleteTagsResult) error
• type MatchInformation
• type MatrixResult
  • func (r MatrixResult) Len() int
  • func (r MatrixResult) Less(i, j int) bool
  • func (r MatrixResult) Sort()
  • func (r MatrixResult) Swap(i, j int)
• type ParsePromCompressedRequestResult
  • func ParsePromCompressedRequest(r *http.Request) (ParsePromCompressedRequestResult, *xhttp.ParseError)
• type Response
  • func (r Response) Matches(other Response) (MatchInformation, error)
• type ScalarResult
• type StringResult
• type TagCompletionQueries
  • func ParseTagCompletionParamsToQueries(r *http.Request) (TagCompletionQueries, *xhttp.ParseError)
• type Tags
• type TimeoutOpts
• type Value
• type Values
• type VectorResult
  • func (r VectorResult) Len() int
  • func (r VectorResult) Less(i, j int) bool
  • func (r VectorResult) Sort()
  • func (r VectorResult) Swap(i, j int)

Functions

func FilterSeriesByOptions

func FilterSeriesByOptions(
	series []*ts.Series,
	opts *storage.FetchOptions,
) []*ts.Series

FilterSeriesByOptions removes series tags based on options.

func ParseRequestTimeout

func ParseRequestTimeout(
	r *http.Request,
	configFetchTimeout time.Duration,
) (time.Duration, error)

ParseRequestTimeout parses the input request timeout with a default.

func ParseSeriesMatchQuery

func ParseSeriesMatchQuery(
	r *http.Request,
	parseOpts xpromql.ParseOptions,
	tagOptions models.TagOptions,
) ([]*storage.FetchQuery, *xhttp.ParseError)

ParseSeriesMatchQuery parses all params from the GET request.

func RenderListTagResultsJSON

func RenderListTagResultsJSON(
	w io.Writer,
	result *consolidators.CompleteTagsResult,
) error

RenderListTagResultsJSON renders list tag results to json format.

func RenderSeriesMatchResultsJSON

func RenderSeriesMatchResultsJSON(
	w io.Writer,
	results []models.Metrics,
	dropRole bool,
) error

RenderSeriesMatchResultsJSON renders series match results to json format.

func RenderTagCompletionResultsJSON

func RenderTagCompletionResultsJSON(
	w io.Writer, result consolidators.CompleteTagsResult) error

RenderTagCompletionResultsJSON renders tag completion results to json format.

func RenderTagValuesResultsJSON

func RenderTagValuesResultsJSON(
	w io.Writer,
	result *consolidators.CompleteTagsResult,
) error

RenderTagValuesResultsJSON renders tag values results to json format.

Types

type MatchInformation

type MatchInformation struct {
	// FullMatch indicates a full match.
	FullMatch bool
	// NoMatch indicates that the responses do not match sufficiently.
	NoMatch bool
}

MatchInformation describes how well two responses match.

type MatrixResult

type MatrixResult struct {
	Result []matrixRow `json:"result"`
}

MatrixResult contains a list matrixRow.

func (MatrixResult) Len

func (r MatrixResult) Len() int

Len is the number of elements in the collection.

func (MatrixResult) Less

func (r MatrixResult) Less(i, j int) bool

Less reports whether the element with index i should sort before the element with index j.

func (MatrixResult) Sort

func (r MatrixResult) Sort()

Sort sorts the MatrixResult.

func (MatrixResult) Swap

func (r MatrixResult) Swap(i, j int)

Swap swaps the elements with indexes i and j.

type ParsePromCompressedRequestResult

type ParsePromCompressedRequestResult struct {
	CompressedBody   []byte
	UncompressedBody []byte
}

ParsePromCompressedRequestResult is the result of a ParsePromCompressedRequest call.

func ParsePromCompressedRequest

func ParsePromCompressedRequest(
	r *http.Request,
) (ParsePromCompressedRequestResult, *xhttp.ParseError)

ParsePromCompressedRequest parses a snappy compressed request from Prometheus.

type Response

type Response struct {
	// Status is the response status.
	Status string `json:"status"`
	// Data is the response data.
	Data data `json:"data"`
}

Response represents Prometheus's query response.

func (Response) Matches

func (r Response) Matches(other Response) (MatchInformation, error)

Matches compares two responses and determines how closely they match.

type ScalarResult

type ScalarResult struct {
	Result Value `json:"result"`
}

ScalarResult is the scalar Value for the response.

type StringResult

type StringResult struct {
	Result Value `json:"result"`
}

StringResult is the string Value for the response.

type TagCompletionQueries

type TagCompletionQueries struct {
	// Queries are the tag completion queries.
	Queries []*storage.CompleteTagsQuery
	// NameOnly indicates name only
	NameOnly bool
}

TagCompletionQueries are tag completion queries.

func ParseTagCompletionParamsToQueries

func ParseTagCompletionParamsToQueries(
	r *http.Request,
) (TagCompletionQueries, *xhttp.ParseError)

ParseTagCompletionParamsToQueries parses all params from the GET request. Returns queries, a boolean indicating if the query completes names only, and any errors.

type Tags

type Tags map[string]string

Tags is a simple representation of Prometheus tags.

type TimeoutOpts

type TimeoutOpts struct {
	FetchTimeout time.Duration
}

TimeoutOpts stores options related to various timeout configurations.

type Value

type Value []interface{}

Value is a single value for Prometheus Result.

type Values

type Values []Value

Values is a list of values for the Prometheus Result.

type VectorResult

type VectorResult struct {
	Result []vectorItem `json:"result"`
}

VectorResult contains a list of vectorItem.

func (VectorResult) Len

func (r VectorResult) Len() int

Len is the number of elements in the vector.

func (VectorResult) Less

func (r VectorResult) Less(i, j int) bool

Less reports whether the element with index i should sort before the element with index j.

func (VectorResult) Sort

func (r VectorResult) Sort()

Sort sorts the VectorResult.

func (VectorResult) Swap

func (r VectorResult) Swap(i, j int)

Swap swaps the elements with indexes i and j.