package promql

import "github.com/influxdata/flux/stdlib/internal/promql"

Index

Constants 

const ChangesKind = "changes"
const DefaultUpperBoundColumnLabel = "le"
const EmptyTableKind = "emptyTable"
const ExtrapolatedRateKind = "extrapolatedRate"
const HistogramQuantileKind = "promHistogramQuantile"

TODO: Added "prom" prefix to avoid duplicate registration error. Decide whether to remove universe version of this function. 

const HoltWintersKind = "promHoltWinters"
const InstantRateKind = "instantRate"
const (
	// LabelReplaceKind is the Kind for the LabelReplace Flux function
	LabelReplaceKind = "labelReplace"
)
const LinearRegressionKind = "linearRegression"
const ResetsKind = "resets"
const (
	// TimestampKind is the Kind for the Timestamp Flux function
	TimestampKind = "timestamp"
)

Functions

func NewChangesTransformation 

func NewChangesTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *ChangesProcedureSpec) *changesTransformation

func NewExtrapolatedRateTransformation 

func NewExtrapolatedRateTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *ExtrapolatedRateProcedureSpec) *extrapolatedRateTransformation

func NewHistogramQuantileTransformation 

func NewHistogramQuantileTransformation(
	d execute.Dataset,
	cache execute.TableBuilderCache,
	spec *HistogramQuantileProcedureSpec,
) execute.Transformation

func NewHoltWintersTransformation 

func NewHoltWintersTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *HoltWintersProcedureSpec) *holtWintersTransformation

func NewInstantRateTransformation 

func NewInstantRateTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *InstantRateProcedureSpec) *instantRateTransformation

func NewLabelReplaceTransformation 

func NewLabelReplaceTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *LabelReplaceProcedureSpec) *labelReplaceTransformation

func NewLinearRegressionTransformation 

func NewLinearRegressionTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *LinearRegressionProcedureSpec) *linearRegressionTransformation

func NewResetsTransformation 

func NewResetsTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *ResetsProcedureSpec) *resetsTransformation

func NewTimestampTransformation 

func NewTimestampTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *TimestampProcedureSpec) *timestampTransformation

Types

type ChangesOpSpec 

type ChangesOpSpec struct{}

func (*ChangesOpSpec) Kind 

func (s *ChangesOpSpec) Kind() flux.OperationKind

type ChangesProcedureSpec 

type ChangesProcedureSpec struct {
	plan.DefaultCost
}

func (*ChangesProcedureSpec) Copy 

func (s *ChangesProcedureSpec) Copy() plan.ProcedureSpec

func (*ChangesProcedureSpec) Kind 

func (s *ChangesProcedureSpec) Kind() plan.ProcedureKind

func (*ChangesProcedureSpec) TriggerSpec 

func (s *ChangesProcedureSpec) TriggerSpec() plan.TriggerSpec

TriggerSpec implements plan.TriggerAwareProcedureSpec

type EmptyTableOpSpec 

type EmptyTableOpSpec struct{}

func (*EmptyTableOpSpec) Kind 

func (s *EmptyTableOpSpec) Kind() flux.OperationKind

type EmptyTableProcedureSpec 

type EmptyTableProcedureSpec struct {
	plan.DefaultCost
}

func (*EmptyTableProcedureSpec) Copy 

func (s *EmptyTableProcedureSpec) Copy() plan.ProcedureSpec

func (*EmptyTableProcedureSpec) Kind 

func (s *EmptyTableProcedureSpec) Kind() plan.ProcedureKind

type EmptyTableSource 

type EmptyTableSource struct {
	execute.ExecutionNode
	// contains filtered or unexported fields
}

func (*EmptyTableSource) AddTransformation 

func (s *EmptyTableSource) AddTransformation(t execute.Transformation)

func (*EmptyTableSource) Run 

func (s *EmptyTableSource) Run(ctx context.Context)

type ExtrapolatedRateOpSpec 

type ExtrapolatedRateOpSpec struct {
	IsCounter bool `json:"isCounter"`
	IsRate    bool `json:"isRate"`
}

func (*ExtrapolatedRateOpSpec) Kind 

func (s *ExtrapolatedRateOpSpec) Kind() flux.OperationKind

type ExtrapolatedRateProcedureSpec 

type ExtrapolatedRateProcedureSpec struct {
	plan.DefaultCost
	IsCounter bool
	IsRate    bool
}

func (*ExtrapolatedRateProcedureSpec) Copy 

func (s *ExtrapolatedRateProcedureSpec) Copy() plan.ProcedureSpec

func (*ExtrapolatedRateProcedureSpec) Kind 

func (s *ExtrapolatedRateProcedureSpec) Kind() plan.ProcedureKind

func (*ExtrapolatedRateProcedureSpec) TriggerSpec 

func (s *ExtrapolatedRateProcedureSpec) TriggerSpec() plan.TriggerSpec

TriggerSpec implements plan.TriggerAwareProcedureSpec

type HistogramQuantileOpSpec 

type HistogramQuantileOpSpec struct {
	Quantile         float64 `json:"quantile"`
	CountColumn      string  `json:"countColumn"`
	UpperBoundColumn string  `json:"upperBoundColumn"`
	ValueColumn      string  `json:"valueColumn"`
}

func (*HistogramQuantileOpSpec) Kind 

func (s *HistogramQuantileOpSpec) Kind() flux.OperationKind

type HistogramQuantileProcedureSpec 

type HistogramQuantileProcedureSpec struct {
	plan.DefaultCost
	Quantile         float64 `json:"quantile"`
	CountColumn      string  `json:"countColumn"`
	UpperBoundColumn string  `json:"upperBoundColumn"`
	ValueColumn      string  `json:"valueColumn"`
}

func (*HistogramQuantileProcedureSpec) Copy 

func (s *HistogramQuantileProcedureSpec) Copy() plan.ProcedureSpec

func (*HistogramQuantileProcedureSpec) Kind 

func (s *HistogramQuantileProcedureSpec) Kind() plan.ProcedureKind

type HoltWintersOpSpec 

type HoltWintersOpSpec struct {
	SmoothingFactor float64 `json:"smoothingFactor"`
	TrendFactor     float64 `json:"trendFactor"`
}

func (*HoltWintersOpSpec) Kind 

func (s *HoltWintersOpSpec) Kind() flux.OperationKind

type HoltWintersProcedureSpec 

type HoltWintersProcedureSpec struct {
	plan.DefaultCost
	SmoothingFactor float64
	TrendFactor     float64
}

func (*HoltWintersProcedureSpec) Copy 

func (s *HoltWintersProcedureSpec) Copy() plan.ProcedureSpec

func (*HoltWintersProcedureSpec) Kind 

func (s *HoltWintersProcedureSpec) Kind() plan.ProcedureKind

func (*HoltWintersProcedureSpec) TriggerSpec 

func (s *HoltWintersProcedureSpec) TriggerSpec() plan.TriggerSpec

TriggerSpec implements plan.TriggerAwareProcedureSpec

type InstantRateOpSpec 

type InstantRateOpSpec struct {
	IsRate bool `json:"isRate"`
}

func (*InstantRateOpSpec) Kind 

func (s *InstantRateOpSpec) Kind() flux.OperationKind

type InstantRateProcedureSpec 

type InstantRateProcedureSpec struct {
	plan.DefaultCost
	IsRate bool
}

func (*InstantRateProcedureSpec) Copy 

func (s *InstantRateProcedureSpec) Copy() plan.ProcedureSpec

func (*InstantRateProcedureSpec) Kind 

func (s *InstantRateProcedureSpec) Kind() plan.ProcedureKind

func (*InstantRateProcedureSpec) TriggerSpec 

func (s *InstantRateProcedureSpec) TriggerSpec() plan.TriggerSpec

TriggerSpec implements plan.TriggerAwareProcedureSpec

type LabelReplaceOpSpec 

type LabelReplaceOpSpec struct {
	Source      string `json:"source"`
	Destination string `json:"destination"`
	Regex       string `json:"regex"`
	Replacement string `json:"replacement"`
}

func (*LabelReplaceOpSpec) Kind 

func (s *LabelReplaceOpSpec) Kind() flux.OperationKind

type LabelReplaceProcedureSpec 

type LabelReplaceProcedureSpec struct {
	plan.DefaultCost
	Source      string
	Destination string
	Regex       string
	Replacement string
}

func (*LabelReplaceProcedureSpec) Copy 

func (s *LabelReplaceProcedureSpec) Copy() plan.ProcedureSpec

func (*LabelReplaceProcedureSpec) Kind 

func (s *LabelReplaceProcedureSpec) Kind() plan.ProcedureKind

type LinearRegressionOpSpec 

type LinearRegressionOpSpec struct {
	Predict bool `json:"predict"`
	// Stored as seconds in float64 to avoid back-and-forth duration conversions from PromQL.
	FromNow float64 `json:"fromNow"`
}

func (*LinearRegressionOpSpec) Kind 

func (s *LinearRegressionOpSpec) Kind() flux.OperationKind

type LinearRegressionProcedureSpec 

type LinearRegressionProcedureSpec struct {
	plan.DefaultCost
	Predict bool
	FromNow float64
}

func (*LinearRegressionProcedureSpec) Copy 

func (s *LinearRegressionProcedureSpec) Copy() plan.ProcedureSpec

func (*LinearRegressionProcedureSpec) Kind 

func (s *LinearRegressionProcedureSpec) Kind() plan.ProcedureKind

func (*LinearRegressionProcedureSpec) TriggerSpec 

func (s *LinearRegressionProcedureSpec) TriggerSpec() plan.TriggerSpec

TriggerSpec implements plan.TriggerAwareProcedureSpec

type ResetsOpSpec 

type ResetsOpSpec struct{}

func (*ResetsOpSpec) Kind 

func (s *ResetsOpSpec) Kind() flux.OperationKind

type ResetsProcedureSpec 

type ResetsProcedureSpec struct {
	plan.DefaultCost
}

func (*ResetsProcedureSpec) Copy 

func (s *ResetsProcedureSpec) Copy() plan.ProcedureSpec

func (*ResetsProcedureSpec) Kind 

func (s *ResetsProcedureSpec) Kind() plan.ProcedureKind

func (*ResetsProcedureSpec) TriggerSpec 

func (s *ResetsProcedureSpec) TriggerSpec() plan.TriggerSpec

TriggerSpec implements plan.TriggerAwareProcedureSpec

type TimestampOpSpec 

type TimestampOpSpec struct{}

func (*TimestampOpSpec) Kind 

func (s *TimestampOpSpec) Kind() flux.OperationKind

type TimestampProcedureSpec 

type TimestampProcedureSpec struct {
	plan.DefaultCost
}

func (*TimestampProcedureSpec) Copy 

func (s *TimestampProcedureSpec) Copy() plan.ProcedureSpec

func (*TimestampProcedureSpec) Kind 

func (s *TimestampProcedureSpec) Kind() plan.ProcedureKind

Source Files

changes.go date_functions.go empty_table.go extrapolated_rate.go histogram_quantile.go holt_winters.go instant_rate.go label_replace.go linear_regression.go resets.go timestamp.go

Version
v0.196.1 (latest)
Published
Feb 19, 2025
Platform
linux/amd64
Imports
15 packages
Last checked
1 day ago –

Tools for package owners.