prometheus

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)
  • func (s *Scanners) Close() error
  • func (p Scanners) NewMatrixSelector(ctx context.Context, opts *query.Options, hints storage.SelectHints, ...) (model.VectorOperator, error)
  • func (p Scanners) NewVectorSelector(_ context.Context, opts *query.Options, hints storage.SelectHints, ...) (model.VectorOperator, 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

Variables

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,
	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
}