utils

Documentation

Index

• func AddTimeFieldWithRange(expr string, timeRange backend.TimeRange) string
• func CalculateStep(minInterval time.Duration, timeRange backend.TimeRange, maxDataPoints int64) time.Duration
• func GetIntervalFrom(dsInterval, queryInterval string, queryIntervalMS int64, ...) (time.Duration, error)
• func GetLocalTimezoneOffsetNsecs() int64
• func GetTime(s string) (time.Time, error)
• func ParseDuration(s string) (time.Duration, error)
• func ParseTime(s string) (float64, error)
• func ParseTimeAt(s string, currentTimestamp float64) (float64, error)
• func Ptr[T any](v T) *T
• func ReplaceTemplateVariable(expr string, interval int64, timeRange backend.TimeRange) string
• func TryParseTimestampRFC3339Nano(s string) (int64, bool)
• func WithIntervalVariable(expr string) bool
• type StreamField
  • func ParseStreamFields(streamFields string) ([]StreamField, error)

Functions

func AddTimeFieldWithRange

func AddTimeFieldWithRange(expr string, timeRange backend.TimeRange) string

AddTimeFieldWithRange adds time field with range to the query

func CalculateStep

func CalculateStep(minInterval time.Duration, timeRange backend.TimeRange, maxDataPoints int64) time.Duration

CalculateStep calculates step by provided max datapoints and timerange

func GetIntervalFrom

func GetIntervalFrom(dsInterval, queryInterval string, queryIntervalMS int64, defaultInterval time.Duration) (time.Duration, error)

GetIntervalFrom returns the minimum interval. dsInterval is the string representation of data source min interval, if configured. queryInterval is the string representation of query interval (min interval), e.g. "10ms" or "10s". queryIntervalMS is a pre-calculated numeric representation of the query interval in milliseconds.

func GetLocalTimezoneOffsetNsecs

func GetLocalTimezoneOffsetNsecs() int64

GetLocalTimezoneOffsetNsecs returns local timezone offset in nanoseconds. It accounts for DST automatically.

func GetTime

func GetTime(s string) (time.Time, error)

GetTime returns time from the given string.

func ParseDuration

func ParseDuration(s string) (time.Duration, error)

ParseDuration parses duration string in Prometheus format

func ParseTime

func ParseTime(s string) (float64, error)

ParseTime parses time s in different formats.

See https://docs.victoriametrics.com/victoriametrics/single-server-victoriametrics/#timestamp-formats

It returns unix timestamp in seconds.

func ParseTimeAt

func ParseTimeAt(s string, currentTimestamp float64) (float64, error)

ParseTimeAt parses time s in different formats, assuming the given currentTimestamp.

See https://docs.victoriametrics.com/victoriametrics/single-server-victoriametrics/#timestamp-formats

It returns unix timestamp in seconds.

func Ptr

func Ptr[T any](v T) *T

Ptr returns a pointer to the given value.

func ReplaceTemplateVariable

func ReplaceTemplateVariable(expr string, interval int64, timeRange backend.TimeRange) string

ReplaceTemplateVariable get query and use it expression to remove grafana template variables with

func TryParseTimestampRFC3339Nano

func TryParseTimestampRFC3339Nano(s string) (int64, bool)

TryParseTimestampRFC3339Nano parses s as RFC3339 with optional nanoseconds part and timezone offset and returns unix timestamp in nanoseconds.

If s doesn't contain timezone offset, then the local timezone is used.

The returned timestamp can be negative if s is smaller than 1970 year.x

func WithIntervalVariable

func WithIntervalVariable(expr string) bool

WithIntervalVariable checks if the expression contains interval variable

Types

type StreamField

type StreamField struct {
	Label string
	Value string
}

StreamField represents the label values pair of the _stream fields in the log struct

func ParseStreamFields

func ParseStreamFields(streamFields string) ([]StreamField, error)

ParseStreamFields collect labels values pair from the _stream field