engine

package

v1.21.1 Latest Latest Go to latest Published: Jun 5, 2026 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/cortexproject/cortex

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func AddEngineTypeToContext(ctx context.Context, r *http.Request) context.Context
type Engine
- func New(opts promql.EngineOpts, thanosEngineCfg ThanosEngineConfig, ...) *Engine
type QueryEngine
type ThanosEngineConfig
- func (cfg *ThanosEngineConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)
- func (cfg *ThanosEngineConfig) Validate() error
type Type
- func GetEngineType(ctx context.Context) Type

Constants ¶

View Source

const TypeHeader = "X-PromQL-EngineType"

Variables ¶

This section is empty.

Functions ¶

func AddEngineTypeToContext ¶

func AddEngineTypeToContext(ctx context.Context, r *http.Request) context.Context

Types ¶

type Engine ¶

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

func New ¶

func New(opts promql.EngineOpts, thanosEngineCfg ThanosEngineConfig, reg prometheus.Registerer) *Engine

func (*Engine) MakeInstantQueryFromPlan ¶

func (qf *Engine) MakeInstantQueryFromPlan(ctx context.Context, q storage.Queryable, opts promql.QueryOpts, root logicalplan.Node, ts time.Time, qs string) (promql.Query, error)

func (*Engine) MakeRangeQueryFromPlan ¶

func (qf *Engine) MakeRangeQueryFromPlan(ctx context.Context, q storage.Queryable, opts promql.QueryOpts, root logicalplan.Node, start time.Time, end time.Time, interval time.Duration, qs string) (promql.Query, error)

func (*Engine) NewInstantQuery ¶

func (qf *Engine) NewInstantQuery(ctx context.Context, q storage.Queryable, opts promql.QueryOpts, qs string, ts time.Time) (promql.Query, error)

func (*Engine) NewRangeQuery ¶

func (qf *Engine) NewRangeQuery(ctx context.Context, q storage.Queryable, opts promql.QueryOpts, qs string, start, end time.Time, interval time.Duration) (promql.Query, error)

type QueryEngine ¶

type QueryEngine interface {
	promql.QueryEngine
	MakeInstantQueryFromPlan(ctx context.Context, q storage.Queryable, opts promql.QueryOpts, root logicalplan.Node, ts time.Time, qs string) (promql.Query, error)
	MakeRangeQueryFromPlan(ctx context.Context, q storage.Queryable, opts promql.QueryOpts, root logicalplan.Node, start time.Time, end time.Time, interval time.Duration, qs string) (promql.Query, error)
}

type ThanosEngineConfig ¶

type ThanosEngineConfig struct {
	Enabled             bool                    `yaml:"enabled"`
	EnableXFunctions    bool                    `yaml:"enable_x_functions"`
	Optimizers          string                  `yaml:"optimizers"`
	DecodingConcurrency int                     `yaml:"decoding_concurrency"`
	LogicalOptimizers   []logicalplan.Optimizer `yaml:"-"`
}

ThanosEngineConfig contains the configuration to create engine.

func (*ThanosEngineConfig) RegisterFlagsWithPrefix ¶

func (cfg *ThanosEngineConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)

func (*ThanosEngineConfig) Validate ¶

func (cfg *ThanosEngineConfig) Validate() error

type Type ¶

type Type string

const (
	Prometheus Type = "prometheus"
	Thanos     Type = "thanos"
	None       Type = "none"
)

func GetEngineType ¶

func GetEngineType(ctx context.Context) Type

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL