scalars

Documentation

Index

• type InstantVectorToScalar
  • func NewInstantVectorToScalar(inner types.InstantVectorOperator, timeRange types.QueryTimeRange, ...) *InstantVectorToScalar
  • func (i *InstantVectorToScalar) Close()
  • func (i *InstantVectorToScalar) ExpressionPosition() posrange.PositionRange
  • func (i *InstantVectorToScalar) GetValues(ctx context.Context) (types.ScalarData, error)
• type ScalarConstant
  • func NewScalarConstant(value float64, timeRange types.QueryTimeRange, ...) *ScalarConstant
  • func (s *ScalarConstant) Close()
  • func (s *ScalarConstant) ExpressionPosition() posrange.PositionRange
  • func (s *ScalarConstant) GetValues(_ context.Context) (types.ScalarData, error)
• type ScalarToInstantVector
  • func NewScalarToInstantVector(scalar types.ScalarOperator, expressionPosition posrange.PositionRange) *ScalarToInstantVector
  • func (s *ScalarToInstantVector) Close()
  • func (s *ScalarToInstantVector) ExpressionPosition() posrange.PositionRange
  • func (s *ScalarToInstantVector) NextSeries(ctx context.Context) (types.InstantVectorSeriesData, error)
  • func (s *ScalarToInstantVector) SeriesMetadata(_ context.Context) ([]types.SeriesMetadata, error)
• type UnaryNegationOfScalar
  • func NewUnaryNegationOfScalar(inner types.ScalarOperator, expressionPosition posrange.PositionRange) *UnaryNegationOfScalar
  • func (u *UnaryNegationOfScalar) Close()
  • func (u *UnaryNegationOfScalar) ExpressionPosition() posrange.PositionRange
  • func (u *UnaryNegationOfScalar) GetValues(ctx context.Context) (types.ScalarData, error)

Types

type InstantVectorToScalar

type InstantVectorToScalar struct {
	Inner                    types.InstantVectorOperator
	TimeRange                types.QueryTimeRange
	MemoryConsumptionTracker *limiting.MemoryConsumptionTracker
	// contains filtered or unexported fields
}

InstantVectorToScalar is an operator that implements the scalar() function.

func NewInstantVectorToScalar

func NewInstantVectorToScalar(
	inner types.InstantVectorOperator,
	timeRange types.QueryTimeRange,
	memoryConsumptionTracker *limiting.MemoryConsumptionTracker,
	expressionPosition posrange.PositionRange,
) *InstantVectorToScalar

func (*InstantVectorToScalar) Close

func (i *InstantVectorToScalar) Close()

func (*InstantVectorToScalar) ExpressionPosition

func (i *InstantVectorToScalar) ExpressionPosition() posrange.PositionRange

func (*InstantVectorToScalar) GetValues

func (i *InstantVectorToScalar) GetValues(ctx context.Context) (types.ScalarData, error)

type ScalarConstant

type ScalarConstant struct {
	Value                    float64
	TimeRange                types.QueryTimeRange
	MemoryConsumptionTracker *limiting.MemoryConsumptionTracker
	// contains filtered or unexported fields
}

func NewScalarConstant

func NewScalarConstant(
	value float64,
	timeRange types.QueryTimeRange,
	memoryConsumptionTracker *limiting.MemoryConsumptionTracker,
	expressionPosition posrange.PositionRange,
) *ScalarConstant

func (*ScalarConstant) Close

func (s *ScalarConstant) Close()

func (*ScalarConstant) ExpressionPosition

func (s *ScalarConstant) ExpressionPosition() posrange.PositionRange

func (*ScalarConstant) GetValues

func (s *ScalarConstant) GetValues(_ context.Context) (types.ScalarData, error)

type ScalarToInstantVector

type ScalarToInstantVector struct {
	Scalar types.ScalarOperator
	// contains filtered or unexported fields
}

ScalarToInstantVector is an operator that implements the vector() function.

func NewScalarToInstantVector

func NewScalarToInstantVector(scalar types.ScalarOperator, expressionPosition posrange.PositionRange) *ScalarToInstantVector

func (*ScalarToInstantVector) Close

func (s *ScalarToInstantVector) Close()

func (*ScalarToInstantVector) ExpressionPosition

func (s *ScalarToInstantVector) ExpressionPosition() posrange.PositionRange

func (*ScalarToInstantVector) NextSeries

func (s *ScalarToInstantVector) NextSeries(ctx context.Context) (types.InstantVectorSeriesData, error)

func (*ScalarToInstantVector) SeriesMetadata

func (s *ScalarToInstantVector) SeriesMetadata(_ context.Context) ([]types.SeriesMetadata, error)

type UnaryNegationOfScalar

type UnaryNegationOfScalar struct {
	Inner types.ScalarOperator
	// contains filtered or unexported fields
}

func NewUnaryNegationOfScalar

func NewUnaryNegationOfScalar(inner types.ScalarOperator, expressionPosition posrange.PositionRange) *UnaryNegationOfScalar

func (*UnaryNegationOfScalar) Close

func (u *UnaryNegationOfScalar) Close()

func (*UnaryNegationOfScalar) ExpressionPosition

func (u *UnaryNegationOfScalar) ExpressionPosition() posrange.PositionRange

func (*UnaryNegationOfScalar) GetValues

func (u *UnaryNegationOfScalar) GetValues(ctx context.Context) (types.ScalarData, error)