prometheus

package

v0.2.1 Latest Latest Go to latest Published: Dec 16, 2025 License: Apache-2.0 Imports: 26 Imported by: 0

Details

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

Repository

github.com/oteldb/promql-engine

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func NewMatrixSelector(pool *model.VectorPool, selector SeriesSelector, functionName string, ...) (model.VectorOperator, error)
func NewVectorSelector(pool *model.VectorPool, selector SeriesSelector, queryOpts *query.Options, ...) model.VectorOperator
type Filter
- func NewFilter(matchers []*labels.Matcher) Filter
type Scanners
- func NewPrometheusScanners(queryable storage.Queryable, qOpts *query.Options, lplan logicalplan.Plan) (*Scanners, error)
type SelectorPool
- func NewSelectorPool(querier storage.Querier) *SelectorPool
- func (p *SelectorPool) GetFilteredSelector(mint, maxt, step int64, matchers, filters []*labels.Matcher, ...) SeriesSelector
- func (p *SelectorPool) GetSelector(mint, maxt, step int64, matchers []*labels.Matcher, hints storage.SelectHints) SeriesSelector
type SeriesSelector
- func NewFilteredSelector(selector *seriesSelector, filter Filter) SeriesSelector
type SignedSeries

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrNativeHistogramsNotSupported = errors.New("native histograms are not supported in extended range functions")

Functions ¶

func NewMatrixSelector ¶

func NewMatrixSelector(
	pool *model.VectorPool,
	selector SeriesSelector,
	functionName string,
	arg float64,
	arg2 float64,
	opts *query.Options,
	selectRange, offset time.Duration,
	batchSize int64,
	shard, numShard int,
) (model.VectorOperator, error)

NewMatrixSelector creates operator which selects vector of series over time.

func NewVectorSelector ¶

func NewVectorSelector(
	pool *model.VectorPool,
	selector SeriesSelector,
	queryOpts *query.Options,
	offset time.Duration,
	batchSize int64,
	selectTimestamp bool,
	shard, numShards int,
) model.VectorOperator

NewVectorSelector creates operator which selects vector of series.

Types ¶

type Filter ¶

type Filter interface {
	Matches(series storage.Series) bool
	Matchers() []*labels.Matcher
}

func NewFilter ¶

func NewFilter(matchers []*labels.Matcher) Filter

type Scanners ¶

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

func NewPrometheusScanners ¶

func NewPrometheusScanners(queryable storage.Queryable, qOpts *query.Options, lplan logicalplan.Plan) (*Scanners, error)

func (*Scanners) Close ¶

func (s *Scanners) Close() error

func (Scanners) NewMatrixSelector ¶

func (p Scanners) NewMatrixSelector(
	ctx context.Context,
	opts *query.Options,
	hints storage.SelectHints,
	logicalNode logicalplan.MatrixSelector,
	call logicalplan.FunctionCall,
) (model.VectorOperator, error)

func (Scanners) NewVectorSelector ¶

func (p Scanners) NewVectorSelector(
	_ context.Context,
	opts *query.Options,
	hints storage.SelectHints,
	logicalNode logicalplan.VectorSelector,
) (model.VectorOperator, error)

type SelectorPool ¶

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

func NewSelectorPool ¶

func NewSelectorPool(querier storage.Querier) *SelectorPool

func (*SelectorPool) GetFilteredSelector ¶

func (p *SelectorPool) GetFilteredSelector(mint, maxt, step int64, matchers, filters []*labels.Matcher, hints storage.SelectHints) SeriesSelector

func (*SelectorPool) GetSelector ¶

func (p *SelectorPool) GetSelector(mint, maxt, step int64, matchers []*labels.Matcher, hints storage.SelectHints) SeriesSelector

type SeriesSelector ¶

type SeriesSelector interface {
	GetSeries(ctx context.Context, shard, numShards int) ([]SignedSeries, error)
	Matchers() []*labels.Matcher
}

func NewFilteredSelector ¶

func NewFilteredSelector(selector *seriesSelector, filter Filter) SeriesSelector

type SignedSeries ¶

type SignedSeries struct {
	storage.Series
	Signature uint64
}

Source Files ¶

View all Source files

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