promql

Documentation

Index

• func AdjustStartEnd(start, end, step int64) (int64, int64)
• func Exec(ec *EvalConfig, q string, isFirstPointOnly bool) ([]netstorage.Result, error)
• func InitRollupResultCache(cachePath string)
• func IsMetricSelectorWithRollup(s string) (childQuery string, window, offset string)
• func IsRollup(s string) (childQuery string, window, step, offset string)
• func ParseMetricSelector(s string) ([]storage.TagFilter, error)
• func ResetRollupResultCache()
• func ResetRollupResultCacheIfNeeded(mrs []storage.MetricRow)
• func StopRollupResultCache()
• func ValidateMaxPointsPerTimeseries(start, end, step int64) error
• func WriteActiveQueries(w io.Writer)
• type EvalConfig

Functions

func AdjustStartEnd

func AdjustStartEnd(start, end, step int64) (int64, int64)

AdjustStartEnd adjusts start and end values, so response caching may be enabled.

See EvalConfig.mayCache for details.

func Exec

func Exec(ec *EvalConfig, q string, isFirstPointOnly bool) ([]netstorage.Result, error)

Exec executes q for the given ec.

func InitRollupResultCache

func InitRollupResultCache(cachePath string)

InitRollupResultCache initializes the rollupResult cache

func IsMetricSelectorWithRollup

func IsMetricSelectorWithRollup(s string) (childQuery string, window, offset string)

IsMetricSelectorWithRollup verifies whether s contains PromQL metric selector wrapped into rollup.

It returns the wrapped query with the corresponding window with offset.

func IsRollup

func IsRollup(s string) (childQuery string, window, step, offset string)

IsRollup verifies whether s is a rollup with non-empty window.

It returns the wrapped query with the corresponding window, step and offset.

func ParseMetricSelector

func ParseMetricSelector(s string) ([]storage.TagFilter, error)

ParseMetricSelector parses s containing PromQL metric selector and returns the corresponding LabelFilters.

func ResetRollupResultCache

func ResetRollupResultCache()

ResetRollupResultCache resets rollup result cache.

func ResetRollupResultCacheIfNeeded

func ResetRollupResultCacheIfNeeded(mrs []storage.MetricRow)

ResetRollupResultCacheIfNeeded resets rollup result cache if mrs contains timestamps outside `now - search.cacheTimestampOffset`.

func StopRollupResultCache

func StopRollupResultCache()

StopRollupResultCache closes the rollupResult cache.

func ValidateMaxPointsPerTimeseries

func ValidateMaxPointsPerTimeseries(start, end, step int64) error

ValidateMaxPointsPerTimeseries checks the maximum number of points that may be returned per each time series.

The number mustn't exceed -search.maxPointsPerTimeseries.

func WriteActiveQueries

func WriteActiveQueries(w io.Writer)

WriteActiveQueries writes active queries to w.

The written active queries are sorted in descending order of their exeuction duration.

Types

type EvalConfig

type EvalConfig struct {
	Start int64
	End   int64
	Step  int64

	// QuotedRemoteAddr contains quoted remote address.
	QuotedRemoteAddr string

	Deadline searchutils.Deadline

	MayCache bool

	// LookbackDelta is analog to `-query.lookback-delta` from Prometheus.
	LookbackDelta int64

	// EnforcedTagFilters used for apply additional label filters to query.
	EnforcedTagFilters []storage.TagFilter
	// contains filtered or unexported fields
}

EvalConfig is the configuration required for query evaluation via Exec