promql

Documentation

Index

• func ExtractSourceIds(query string) ([]string, error)
• func ParseDuration(param string) (time.Duration, error)
• func ParseStep(param string) (time.Duration, error)
• func ParseTime(param string) (time.Time, error)
• func ReplaceSourceIdSets(query string, sourceIDExpansions map[string][]string) (string, error)
• func SanitizeMetricName(name string) string
• type DataReader
• type LogCacheQuerier
  • func (l *LogCacheQuerier) Close() error
  • func (l *LogCacheQuerier) LabelValues(name string) ([]string, error)
  • func (l *LogCacheQuerier) Select(params *storage.SelectParams, ll ...*labels.Matcher) (storage.SeriesSet, error)
• type Metrics
• type PromQL
  • func New(r DataReader, m Metrics, log *log.Logger, queryTimeout time.Duration) *PromQL
  • func (q *PromQL) InstantQuery(ctx context.Context, req *logcache_v1.PromQL_InstantQueryRequest) (*logcache_v1.PromQL_InstantQueryResult, error)
  • func (q *PromQL) RangeQuery(ctx context.Context, req *logcache_v1.PromQL_RangeQueryRequest) (*logcache_v1.PromQL_RangeQueryResult, error)

Functions

func ExtractSourceIds

func ExtractSourceIds(query string) ([]string, error)

TODO - move elsewhere and clean up [#160353522]

func ParseDuration

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

func ParseStep

func ParseStep(param string) (time.Duration, error)

func ParseTime

func ParseTime(param string) (time.Time, error)

func ReplaceSourceIdSets

func ReplaceSourceIdSets(query string, sourceIDExpansions map[string][]string) (string, error)

func SanitizeMetricName

func SanitizeMetricName(name string) string

Types

type DataReader

type DataReader interface {
	Read(ctx context.Context, in *logcache_v1.ReadRequest) (*logcache_v1.ReadResponse, error)
}

type LogCacheQuerier

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

func (*LogCacheQuerier) Close

func (l *LogCacheQuerier) Close() error

func (*LogCacheQuerier) LabelValues

func (l *LogCacheQuerier) LabelValues(name string) ([]string, error)

func (*LogCacheQuerier) Select

func (l *LogCacheQuerier) Select(params *storage.SelectParams, ll ...*labels.Matcher) (storage.SeriesSet, error)

type Metrics

type Metrics interface {
	NewCounter(name string) func(delta uint64)
	NewGauge(name, unit string) func(value float64)
}

type PromQL

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

func New

func New(
	r DataReader,
	m Metrics,
	log *log.Logger,
	queryTimeout time.Duration,
) *PromQL

func (*PromQL) InstantQuery

func (q *PromQL) InstantQuery(ctx context.Context, req *logcache_v1.PromQL_InstantQueryRequest) (*logcache_v1.PromQL_InstantQueryResult, error)

func (*PromQL) RangeQuery

func (q *PromQL) RangeQuery(ctx context.Context, req *logcache_v1.PromQL_RangeQueryRequest) (*logcache_v1.PromQL_RangeQueryResult, error)