engine

type AnalyzeOutputNode struct {
	OperatorTelemetry telemetry.OperatorTelemetry `json:"telemetry,omitempty"`
	Children          []*AnalyzeOutputNode        `json:"children,omitempty"`
	// contains filtered or unexported fields
}

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

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

type ExplainOutputNode struct {
	OperatorName string              `json:"name,omitempty"`
	Children     []ExplainOutputNode `json:"children,omitempty"`
}

type ExplainableQuery interface {
	promql.Query

	Explain() *ExplainOutputNode
	Analyze() *AnalyzeOutputNode
}

type Opts struct {
	promql.EngineOpts

	// LogicalOptimizers are optimizers that are run if the value is not nil. If it is nil then the default optimizers are run. Default optimizer list is available in the logicalplan package.
	LogicalOptimizers []logicalplan.Optimizer

	// ExtLookbackDelta specifies what time range to use to determine valid previous sample for extended range functions.
	// Defaults to 1 hour if not specified.
	ExtLookbackDelta time.Duration

	// DecodingConcurrency is the maximum number of goroutines that can be used to decode samples. Defaults to GOMAXPROCS / 2.
	DecodingConcurrency int

	// SelectorBatchSize specifies the maximum number of samples to be returned by selectors in a single batch.
	SelectorBatchSize int64

	// EnableXFunctions enables custom xRate, xIncrease and xDelta functions.
	// This will default to false.
	EnableXFunctions bool

	// EnableAnalysis enables query analysis.
	EnableAnalysis bool

	// The Prometheus engine has internal check for duplicate labels produced by functions, aggregations or binary operators.
	// This check can produce false positives when querying time-series data which does not conform to the Prometheus data model,
	// and can be disabled if it leads to false positives.
	DisableDuplicateLabelChecks bool
}

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

type QueryOpts struct {
	// These values are used to implement promql.QueryOpts, they have weird "Param" suffix because
	// they are accessed by methods of the same name.
	LookbackDeltaParam      time.Duration
	EnablePerStepStatsParam bool

	// DecodingConcurrency can be used to override the DecodingConcurrency engine setting.
	DecodingConcurrency int

	// SelectorBatchSize can be used to override the SelectorBatchSize engine setting.
	SelectorBatchSize int64

	// LogicalOptimizers can be used to override the LogicalOptimizers engine setting.
	LogicalOptimizers []logicalplan.Optimizer
}

type QueryType int