topkbottomk

Documentation

Index

• func New(inner types.InstantVectorOperator, param types.ScalarOperator, ...) types.InstantVectorOperator
• type InstantQuery
  • func (t *InstantQuery) Close()
  • func (t *InstantQuery) ExpressionPosition() posrange.PositionRange
  • func (t *InstantQuery) NextSeries(_ context.Context) (types.InstantVectorSeriesData, error)
  • func (t *InstantQuery) SeriesMetadata(ctx context.Context) ([]types.SeriesMetadata, error)
• type RangeQuery
  • func (t *RangeQuery) Close()
  • func (t *RangeQuery) ExpressionPosition() posrange.PositionRange
  • func (t *RangeQuery) NextSeries(ctx context.Context) (types.InstantVectorSeriesData, error)
  • func (t *RangeQuery) SeriesMetadata(ctx context.Context) ([]types.SeriesMetadata, error)

Functions

func New

func New(
	inner types.InstantVectorOperator,
	param types.ScalarOperator,
	timeRange types.QueryTimeRange,
	grouping []string,
	without bool,
	isTopK bool,
	memoryConsumptionTracker *limiting.MemoryConsumptionTracker,
	annotations *annotations.Annotations,
	expressionPosition posrange.PositionRange,
) types.InstantVectorOperator

Types

type InstantQuery

type InstantQuery struct {
	Inner                    types.InstantVectorOperator
	Param                    types.ScalarOperator
	TimeRange                types.QueryTimeRange
	Grouping                 []string // If this is a 'without' aggregation, New will ensure that this slice contains __name__.
	Without                  bool
	MemoryConsumptionTracker *limiting.MemoryConsumptionTracker
	IsTopK                   bool // If false, this is operator is for bottomk().
	// contains filtered or unexported fields
}

InstantQuery implements topk() and bottomk() for range queries.

func (*InstantQuery) Close

func (t *InstantQuery) Close()

func (*InstantQuery) ExpressionPosition

func (t *InstantQuery) ExpressionPosition() posrange.PositionRange

func (*InstantQuery) NextSeries

func (t *InstantQuery) NextSeries(_ context.Context) (types.InstantVectorSeriesData, error)

func (*InstantQuery) SeriesMetadata

func (t *InstantQuery) SeriesMetadata(ctx context.Context) ([]types.SeriesMetadata, error)

type RangeQuery

type RangeQuery struct {
	Inner                    types.InstantVectorOperator
	Param                    types.ScalarOperator
	TimeRange                types.QueryTimeRange
	Grouping                 []string // If this is a 'without' aggregation, New will ensure that this slice contains __name__.
	Without                  bool
	MemoryConsumptionTracker *limiting.MemoryConsumptionTracker
	IsTopK                   bool // If false, this is operator is for bottomk().
	// contains filtered or unexported fields
}

RangeQuery implements topk() and bottomk() for range queries.

func (*RangeQuery) Close

func (t *RangeQuery) Close()

func (*RangeQuery) ExpressionPosition

func (t *RangeQuery) ExpressionPosition() posrange.PositionRange

func (*RangeQuery) NextSeries

func (t *RangeQuery) NextSeries(ctx context.Context) (types.InstantVectorSeriesData, error)

func (*RangeQuery) SeriesMetadata

func (t *RangeQuery) SeriesMetadata(ctx context.Context) ([]types.SeriesMetadata, error)