searchutils

Documentation

Index

• func GetBool(r *http.Request, argKey string) bool
• func GetDenyPartialResponse(r *http.Request) bool
• func GetDuration(r *http.Request, argKey string, defaultValue int64) (int64, error)
• func GetExtraTagFilters(r *http.Request) ([][]storage.TagFilter, error)
• func GetMaxQueryDuration(r *http.Request) time.Duration
• func GetTime(r *http.Request, argKey string, defaultMs int64) (int64, error)
• func JoinTagFilterss(src, etfs [][]storage.TagFilter) [][]storage.TagFilter
• func ParseMetricSelector(s string) ([]storage.TagFilter, error)
• func ToTagFilters(lfs []metricsql.LabelFilter) []storage.TagFilter
• type Deadline
  • func GetDeadlineForExport(r *http.Request, startTime time.Time) Deadline
  • func GetDeadlineForQuery(r *http.Request, startTime time.Time) Deadline
  • func GetDeadlineForStatusRequest(r *http.Request, startTime time.Time) Deadline
  • func NewDeadline(startTime time.Time, timeout time.Duration, flagHint string) Deadline
  • func (d *Deadline) Deadline() uint64
  • func (d *Deadline) Exceeded() bool
  • func (d *Deadline) String() string

Functions

func GetBool

func GetBool(r *http.Request, argKey string) bool

GetBool returns boolean value from the given argKey query arg.

func GetDenyPartialResponse

func GetDenyPartialResponse(r *http.Request) bool

GetDenyPartialResponse returns whether partial responses are denied.

func GetDuration

func GetDuration(r *http.Request, argKey string, defaultValue int64) (int64, error)

GetDuration returns duration from the given argKey query arg.

func GetExtraTagFilters

func GetExtraTagFilters(r *http.Request) ([][]storage.TagFilter, error)

GetExtraTagFilters returns additional label filters from request.

Label filters can be present in extra_label and extra_filters[] query args. They are combined. For example, the following query args:

extra_label=t1=v1&extra_label=t2=v2&extra_filters[]={env="prod",team="devops"}&extra_filters={env=~"dev|staging",team!="devops"}

should be translated to the following filters joined with "or":

{env="prod",team="devops",t1="v1",t2="v2"}
{env=~"dev|staging",team!="devops",t1="v1",t2="v2"}

func GetMaxQueryDuration

func GetMaxQueryDuration(r *http.Request) time.Duration

GetMaxQueryDuration returns the maximum duration for query from r.

func GetTime

func GetTime(r *http.Request, argKey string, defaultMs int64) (int64, error)

GetTime returns time from the given argKey query arg.

If argKey is missing in r, then defaultMs rounded to seconds is returned. The rounding is needed in order to align query results in Grafana executed at different times. See https://github.com/VictoriaMetrics/VictoriaMetrics/issues/720

func JoinTagFilterss

func JoinTagFilterss(src, etfs [][]storage.TagFilter) [][]storage.TagFilter

JoinTagFilterss adds etfs to every src filter and returns the result.

func ParseMetricSelector

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

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

func ToTagFilters

func ToTagFilters(lfs []metricsql.LabelFilter) []storage.TagFilter

ToTagFilters converts lfs to a slice of storage.TagFilter

Types

type Deadline

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

Deadline contains deadline with the corresponding timeout for pretty error messages.

func GetDeadlineForExport

func GetDeadlineForExport(r *http.Request, startTime time.Time) Deadline

GetDeadlineForExport returns deadline for the given request to /api/v1/export.

func GetDeadlineForQuery

func GetDeadlineForQuery(r *http.Request, startTime time.Time) Deadline

GetDeadlineForQuery returns deadline for the given query r.

func GetDeadlineForStatusRequest

func GetDeadlineForStatusRequest(r *http.Request, startTime time.Time) Deadline

GetDeadlineForStatusRequest returns deadline for the given request to /api/v1/status/*.

func NewDeadline

func NewDeadline(startTime time.Time, timeout time.Duration, flagHint string) Deadline

NewDeadline returns deadline for the given timeout.

flagHint must contain a hit for command-line flag, which could be used in order to increase timeout.

func (*Deadline) Deadline

func (d *Deadline) Deadline() uint64

Deadline returns deadline in unix timestamp seconds.

func (*Deadline) Exceeded

func (d *Deadline) Exceeded() bool

Exceeded returns true if deadline is exceeded.

func (*Deadline) String

func (d *Deadline) String() string

String returns human-readable string representation for d.