selectors

Documentation

Index

• type InstantVectorSelector
  • func (v *InstantVectorSelector) Close()
  • func (v *InstantVectorSelector) ExpressionPosition() posrange.PositionRange
  • func (v *InstantVectorSelector) NextSeries(ctx context.Context) (types.InstantVectorSeriesData, error)
  • func (v *InstantVectorSelector) SeriesMetadata(ctx context.Context) ([]types.SeriesMetadata, error)
• type RangeVectorSelector
  • func NewRangeVectorSelector(selector *Selector, ...) *RangeVectorSelector
  • func (m *RangeVectorSelector) Close()
  • func (m *RangeVectorSelector) ExpressionPosition() posrange.PositionRange
  • func (m *RangeVectorSelector) NextSeries(ctx context.Context) error
  • func (m *RangeVectorSelector) NextStepSamples() (*types.RangeVectorStepData, error)
  • func (m *RangeVectorSelector) Range() time.Duration
  • func (m *RangeVectorSelector) SeriesMetadata(ctx context.Context) ([]types.SeriesMetadata, error)
  • func (m *RangeVectorSelector) StepCount() int
• type Selector
  • func (s *Selector) Close()
  • func (s *Selector) Next(ctx context.Context, existing chunkenc.Iterator) (chunkenc.Iterator, error)
  • func (s *Selector) SeriesMetadata(ctx context.Context) ([]types.SeriesMetadata, error)

Types

type InstantVectorSelector

type InstantVectorSelector struct {
	Selector                 *Selector
	MemoryConsumptionTracker *limiting.MemoryConsumptionTracker
	// contains filtered or unexported fields
}

func (*InstantVectorSelector) Close

func (v *InstantVectorSelector) Close()

func (*InstantVectorSelector) ExpressionPosition

func (v *InstantVectorSelector) ExpressionPosition() posrange.PositionRange

func (*InstantVectorSelector) NextSeries

func (v *InstantVectorSelector) NextSeries(ctx context.Context) (types.InstantVectorSeriesData, error)

func (*InstantVectorSelector) SeriesMetadata

func (v *InstantVectorSelector) SeriesMetadata(ctx context.Context) ([]types.SeriesMetadata, error)

type RangeVectorSelector

type RangeVectorSelector struct {
	Selector *Selector
	// contains filtered or unexported fields
}

func NewRangeVectorSelector

func NewRangeVectorSelector(selector *Selector, memoryConsumptionTracker *limiting.MemoryConsumptionTracker) *RangeVectorSelector

func (*RangeVectorSelector) Close

func (m *RangeVectorSelector) Close()

func (*RangeVectorSelector) ExpressionPosition

func (m *RangeVectorSelector) ExpressionPosition() posrange.PositionRange

func (*RangeVectorSelector) NextSeries

func (m *RangeVectorSelector) NextSeries(ctx context.Context) error

func (*RangeVectorSelector) NextStepSamples

func (m *RangeVectorSelector) NextStepSamples() (*types.RangeVectorStepData, error)

func (*RangeVectorSelector) Range

func (m *RangeVectorSelector) Range() time.Duration

func (*RangeVectorSelector) SeriesMetadata

func (m *RangeVectorSelector) SeriesMetadata(ctx context.Context) ([]types.SeriesMetadata, error)

func (*RangeVectorSelector) StepCount

func (m *RangeVectorSelector) StepCount() int

type Selector

type Selector struct {
	Queryable storage.Queryable
	TimeRange types.QueryTimeRange
	Timestamp *int64 // Milliseconds since Unix epoch, only set if selector uses @ modifier (eg. metric{...} @ 123)
	Offset    int64  // In milliseconds
	Matchers  []*labels.Matcher

	ExpressionPosition posrange.PositionRange

	// Set for instant vector selectors, otherwise 0.
	LookbackDelta time.Duration

	// Set for range vector selectors, otherwise 0.
	Range time.Duration
	// contains filtered or unexported fields
}

func (*Selector) Close

func (s *Selector) Close()

func (*Selector) Next

func (s *Selector) Next(ctx context.Context, existing chunkenc.Iterator) (chunkenc.Iterator, error)

func (*Selector) SeriesMetadata

func (s *Selector) SeriesMetadata(ctx context.Context) ([]types.SeriesMetadata, error)