promql

package

v2.0.1+incompatible Latest Latest Go to latest Published: Oct 25, 2018 License: Apache-2.0 Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

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

TODO - move elsewhere and clean up [#160353522]

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 interface {
	Read(ctx context.Context, in *logcache_v1.ReadRequest) (*logcache_v1.ReadResponse, error)
}

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

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 interface {
	NewCounter(name string) func(delta uint64)
	NewGauge(name string) func(value float64)
}

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

func New(
	r DataReader,
	m Metrics,
	log *log.Logger,
) *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)

Path	Synopsis
data_reader