transformpipe

type AggregatorPipe struct {
	/*
		Duration of windows.
		Calendar months and years
		every supports all valid duration units, including calendar months (1mo) and years (1y).

		Aggregate by week
		When aggregating by week (1w), weeks are determined using the Unix epoch (1970-01-01T00:00:00Z UTC). The Unix epoch was on a Thursday, so all calculated weeks begin on Thursday.
	*/
	Every Duration

	/*
		period
		Duration of the window. Period is the length of each interval. The period can be negative, indicating the start and stop boundaries are reversed. Defaults to every value.
	*/
	Period *Duration

	/*
		column
		The column on which to operate. Defaults to "_value".
	*/
	Column *string

	TimeSrc *string

	TimeDst *string

	CreateEmpty *bool

	Offset *Duration

	Fn TransformFn
}

type BottomPipe struct {
	N       int
	Columns []string
}

type CountPipe struct {
	Column *string
}

type CumulativeSumPipe struct {
	Columns []string
}

type DerivativePipe struct {
	Unit        *Duration
	NonNegative *bool
	Columns     []string
	TimeColumn  *string
}

type DifferencePipe struct {
	NonNegative *bool
	Columns     []string
	KeepFirst   *bool
	InitialZero *bool
}

type DistinctPipe struct {
	Column *string
}

type DoubleEMAPipe struct {
	N int
}

type DropPipe struct {
	Columns []string
}

type Duration string

type ElapsedPipe struct {
	Unit       *Duration
	ColumnName *string
	TimeColumn *string
}

type Estimate string

type ExponentialMovingAveragePipe struct {
	N int
}

type FillPipe struct {
	Value       interface{}
	Column      *string
	UsePrevious *bool
}

type FilterPipe struct {
	Fn string
}

type FirstPipe struct{}

type GroupPipe struct {
	Mode    *string
	Columns []string
}

type IncreasePipe struct {
	Columns []string
}

type IntegralPipe struct {
	Unit        Duration
	Column      *string
	TimeColumn  *string
	Interpolate *string
}

type KaufmansAMAPipe struct {
	N      int
	Column *string
}

type KaufmansERPipe struct {
	N int
}

type KeepPipe struct {
	Columns []string
}

type LastPipe struct{}

type LimitPipe struct {
	N      int
	Offset *int
}

type MaxPipe struct {
	Column *string
}

type MeanPipe struct {
	Column *string
}

type MedianPipe struct {
	Column      *string
	Method      *Estimate
	Compression *float64
}

type MinPipe struct {
	Column *string
}

type ModePipe struct {
	Column *string
}

type MovingAveragePipe struct {
	N int
}

type QuantilePipe struct {
	Q           float64
	Column      *string
	Method      *Estimate
	Compression *float64
}

type RelativeStrengthIndexPipe struct {
	N       int
	Columns []string
}

type SkewPipe struct {
	Column *string
}

type SortPipe struct {
	Columns []string
	Desc    *bool
}

type SpreadPipe struct {
	Column *string
}

type StateCountPipe struct {
	Column *string
	Fn     string
}

type StateDurationPipe struct {
	Column *string
	Fn     string
	Unit   *Duration
}

type StateTrackingPipe struct {
	CountColumn    *string
	DurationColumn *string
	Fn             string
	DurationUnit   *Duration
}

type StddevMode string // "population" or "sample"

type StddevPipe struct {
	Column *string
	Mode   *StddevMode
}

type SumPipe struct {
	Column *string
}

type TailPipe struct {
	N      int
	Offset *int
}

type TimeMovingAveragePipe struct {
	Every  Duration
	Period Duration
	Column *string
}

type TimeShiftPipe struct {
	Duration Duration
	Columns  []string
}

type TimeWeightedAvgPipe struct {
	Unit Duration
}

type ToBoolPipe struct{}

type ToFloatPipe struct{}

type ToIntPipe struct{}

type ToStringPipe struct{}

type ToTimePipe struct{}

type ToUIntPipe struct{}

type TopPipe struct {
	N       int
	Columns []string
}

type TransformFn string

type TransformInput struct {
	Fn     string                 `json:"fn"`
	Params map[string]interface{} `json:"params"`
}

type TransformPipe interface {
	Pipe() (string, error)
}

type TripleEMAPipe struct {
	N int
}

type TripleExponentialDerivativePipe struct {
	N int
}

type TruncateTimeColumnPipe struct {
	Unit Duration
}

type UniquePipe struct {
	Column *string
}

type WindowPipe struct {
	Every       *Duration
	Period      *Duration
	Offset      *Duration
	TimeColumn  *string
	StartColumn *string
	StopColumn  *string
	Location    *string
	CreateEmpty *bool
}

type YieldPipe struct {
	Name *string
}