functions

package
v0.0.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 22, 2018 License: AGPL-3.0, AGPL-3.0-or-later Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source 
const CountKind = "count"
View Source 
const CovarianceKind = "covariance"
View Source 
const DerivativeKind = "derivative"
View Source 
const DifferenceKind = "difference"
View Source 
const DistinctKind = "distinct"
View Source 
const ExactPercentileKind = "exact-percentile"
View Source 
const FilterKind = "filter"
View Source 
const FirstKind = "first"
View Source 
const FromKind = "from"
View Source 
const GroupKind = "group"
View Source 
const IntegralKind = "integral"
View Source 
const JoinKind = "join"
View Source 
const LastKind = "last"
View Source 
const LimitKind = "limit"
View Source 
const MapKind = "map"
View Source 
const MaxKind = "max"
View Source 
const MeanKind = "mean"
View Source 
const MergeJoinKind = "merge-join"
View Source 
const MinKind = "min"
View Source 
const PercentileKind = "percentile"
View Source 
const RangeKind = "range"
View Source 
const SampleKind = "sample"
View Source 
const SetKind = "set"
View Source 
const ShiftKind = "shift"
View Source 
const SkewKind = "skew"
View Source 
const SortKind = "sort"
View Source 
const SpreadKind = "spread"

SpreadKind is the registration name for ifql, query, plan, and execution.

View Source 
const StateTrackingKind = "stateTracking"
View Source 
const StddevKind = "stddev"
View Source 
const SumKind = "sum"
View Source 
const WindowKind = "window"
View Source 
const YieldKind = "yield"

Variables

This section is empty.

Functions

func NewDerivativeTransformation added in v0.0.4 

func NewDerivativeTransformation(d execute.Dataset, cache execute.BlockBuilderCache, spec *DerivativeProcedureSpec) *derivativeTransformation

func NewDifferenceTransformation added in v0.0.4 

func NewDifferenceTransformation(d execute.Dataset, cache execute.BlockBuilderCache, spec *DifferenceProcedureSpec) *differenceTransformation

func NewDistinctTransformation added in v0.0.5 

func NewDistinctTransformation(d execute.Dataset, cache execute.BlockBuilderCache, spec *DistinctProcedureSpec) *distinctTransformation

func NewFilterTransformation added in v0.0.2 

func NewFilterTransformation(d execute.Dataset, cache execute.BlockBuilderCache, spec *FilterProcedureSpec) (*filterTransformation, error)

func NewFixedWindowTransformation 

func NewFixedWindowTransformation(
	d execute.Dataset,
	cache execute.BlockBuilderCache,
	bounds execute.Bounds,
	w execute.Window,
) execute.Transformation

func NewGroupTransformation 

func NewGroupTransformation(d execute.Dataset, cache execute.BlockBuilderCache, spec *GroupProcedureSpec) *groupTransformation

func NewIntegralTransformation added in v0.0.4 

func NewIntegralTransformation(d execute.Dataset, cache execute.BlockBuilderCache, spec *IntegralProcedureSpec, bounds execute.Bounds) *integralTransformation

func NewLimitTransformation 

func NewLimitTransformation(d execute.Dataset, cache execute.BlockBuilderCache, spec *LimitProcedureSpec) *limitTransformation

func NewMapTransformation added in v0.0.4 

func NewMapTransformation(d execute.Dataset, cache execute.BlockBuilderCache, spec *MapProcedureSpec) (*mapTransformation, error)

func NewMergeJoinCache 

func NewMergeJoinCache(joinFn *joinFunc, a *execute.Allocator, leftName, rightName string) *mergeJoinCache

func NewMergeJoinTransformation 

func NewMergeJoinTransformation(d execute.Dataset, cache MergeJoinCache, spec *MergeJoinProcedureSpec, parents []execute.DatasetID, tableNames map[execute.DatasetID]string) *mergeJoinTransformation

func NewRowJoinFunction added in v0.0.4 

func NewRowJoinFunction(fn *semantic.FunctionExpression, parentIDs []execute.DatasetID, tableNames map[execute.DatasetID]string) (*joinFunc, error)

func NewSetTransformation 

func NewSetTransformation(
	d execute.Dataset,
	cache execute.BlockBuilderCache,
	spec *SetProcedureSpec,
) execute.Transformation

func NewShiftTransformation added in v0.0.4 

func NewShiftTransformation(d execute.Dataset, cache execute.BlockBuilderCache, spec *ShiftProcedureSpec) *shiftTransformation

func NewSortTransformation 

func NewSortTransformation(d execute.Dataset, cache execute.BlockBuilderCache, spec *SortProcedureSpec) *sortTransformation

func NewStateTrackingTransformation added in v0.0.5 

func NewStateTrackingTransformation(d execute.Dataset, cache execute.BlockBuilderCache, spec *StateTrackingProcedureSpec) (*stateTrackingTransformation, error)

Types

type AggregateGroupRewriteRule added in v0.0.5 

type AggregateGroupRewriteRule struct {
}

func (AggregateGroupRewriteRule) Rewrite added in v0.0.5 

func (r AggregateGroupRewriteRule) Rewrite(pr *plan.Procedure, planner plan.PlanRewriter) error

func (AggregateGroupRewriteRule) Root added in v0.0.5 

func (r AggregateGroupRewriteRule) Root() plan.ProcedureKind

type CountAgg 

type CountAgg struct {
	// contains filtered or unexported fields
}

func (*CountAgg) DoBool 

func (a *CountAgg) DoBool(vs []bool)

func (*CountAgg) DoFloat 

func (a *CountAgg) DoFloat(vs []float64)

func (*CountAgg) DoInt 

func (a *CountAgg) DoInt(vs []int64)

func (*CountAgg) DoString 

func (a *CountAgg) DoString(vs []string)

func (*CountAgg) DoUInt 

func (a *CountAgg) DoUInt(vs []uint64)

func (*CountAgg) NewBoolAgg 

func (a *CountAgg) NewBoolAgg() execute.DoBoolAgg

func (*CountAgg) NewFloatAgg 

func (a *CountAgg) NewFloatAgg() execute.DoFloatAgg

func (*CountAgg) NewIntAgg 

func (a *CountAgg) NewIntAgg() execute.DoIntAgg

func (*CountAgg) NewStringAgg 

func (a *CountAgg) NewStringAgg() execute.DoStringAgg

func (*CountAgg) NewUIntAgg 

func (a *CountAgg) NewUIntAgg() execute.DoUIntAgg

func (*CountAgg) Type 

func (a *CountAgg) Type() execute.DataType

func (*CountAgg) ValueInt 

func (a *CountAgg) ValueInt() int64

type CountOpSpec 

type CountOpSpec struct {
}

func (*CountOpSpec) Kind 

func (s *CountOpSpec) Kind() query.OperationKind

type CountProcedureSpec 

type CountProcedureSpec struct {
}

func (*CountProcedureSpec) AggregateMethod added in v0.0.5 

func (s *CountProcedureSpec) AggregateMethod() string

func (*CountProcedureSpec) Copy 

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

func (*CountProcedureSpec) Kind 

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

func (*CountProcedureSpec) PushDown 

func (s *CountProcedureSpec) PushDown(root *plan.Procedure, dup func() *plan.Procedure)

func (*CountProcedureSpec) PushDownRules added in v0.0.4 

func (s *CountProcedureSpec) PushDownRules() []plan.PushDownRule

func (*CountProcedureSpec) ReAggregateSpec added in v0.0.5 

func (s *CountProcedureSpec) ReAggregateSpec() plan.ProcedureSpec

type CovarianceOpSpec added in v0.0.4 

type CovarianceOpSpec struct {
	PearsonCorrelation bool `json:"pearsonr"`
}

func (*CovarianceOpSpec) Kind added in v0.0.4 

func (s *CovarianceOpSpec) Kind() query.OperationKind

type CovarianceProcedureSpec added in v0.0.4 

type CovarianceProcedureSpec struct {
	PearsonCorrelation bool
}

func (*CovarianceProcedureSpec) Copy added in v0.0.4 

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

func (*CovarianceProcedureSpec) Kind added in v0.0.4 

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

type CovarianceTransformation added in v0.0.4 

type CovarianceTransformation struct {
	// contains filtered or unexported fields
}

func NewCovarianceTransformation added in v0.0.4 

func NewCovarianceTransformation(d execute.Dataset, cache execute.BlockBuilderCache, spec *CovarianceProcedureSpec, bounds execute.Bounds) *CovarianceTransformation

func (*CovarianceTransformation) DoFloat added in v0.0.4 

func (t *CovarianceTransformation) DoFloat(xs []float64, rr execute.RowReader)

func (*CovarianceTransformation) Finish added in v0.0.4 

func (t *CovarianceTransformation) Finish(id execute.DatasetID, err error)

func (*CovarianceTransformation) Process added in v0.0.4 

func (t *CovarianceTransformation) Process(id execute.DatasetID, b execute.Block) error

func (*CovarianceTransformation) RetractBlock added in v0.0.4 

func (t *CovarianceTransformation) RetractBlock(id execute.DatasetID, meta execute.BlockMetadata) error

func (*CovarianceTransformation) UpdateProcessingTime added in v0.0.4 

func (t *CovarianceTransformation) UpdateProcessingTime(id execute.DatasetID, pt execute.Time) error

func (*CovarianceTransformation) UpdateWatermark added in v0.0.4 

func (t *CovarianceTransformation) UpdateWatermark(id execute.DatasetID, mark execute.Time) error

type DerivativeOpSpec added in v0.0.4 

type DerivativeOpSpec struct {
	Unit        query.Duration `json:"unit"`
	NonNegative bool           `json:"non_negative"`
}

func (*DerivativeOpSpec) Kind added in v0.0.4 

func (s *DerivativeOpSpec) Kind() query.OperationKind

type DerivativeProcedureSpec added in v0.0.4 

type DerivativeProcedureSpec struct {
	Unit        query.Duration `json:"unit"`
	NonNegative bool           `json:"non_negative"`
}

func (*DerivativeProcedureSpec) Copy added in v0.0.4 

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

func (*DerivativeProcedureSpec) Kind added in v0.0.4 

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

type DifferenceOpSpec added in v0.0.4 

type DifferenceOpSpec struct {
	NonNegative bool `json:"non_negative"`
}

func (*DifferenceOpSpec) Kind added in v0.0.4 

func (s *DifferenceOpSpec) Kind() query.OperationKind

type DifferenceProcedureSpec added in v0.0.4 

type DifferenceProcedureSpec struct {
	NonNegative bool `json:"non_negative"`
}

func (*DifferenceProcedureSpec) Copy added in v0.0.4 

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

func (*DifferenceProcedureSpec) Kind added in v0.0.4 

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

type DistinctOpSpec added in v0.0.5 

type DistinctOpSpec struct {
	Column string `json:"column"`
}

func (*DistinctOpSpec) Kind added in v0.0.5 

func (s *DistinctOpSpec) Kind() query.OperationKind

type DistinctProcedureSpec added in v0.0.5 

type DistinctProcedureSpec struct {
	Column string
}

func (*DistinctProcedureSpec) Copy added in v0.0.5 

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

func (*DistinctProcedureSpec) Kind added in v0.0.5 

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

type ExactPercentileAgg added in v0.0.5 

type ExactPercentileAgg struct {
	Quantile float64
	// contains filtered or unexported fields
}

func (*ExactPercentileAgg) DoFloat added in v0.0.5 

func (a *ExactPercentileAgg) DoFloat(vs []float64)

func (*ExactPercentileAgg) NewBoolAgg added in v0.0.5 

func (a *ExactPercentileAgg) NewBoolAgg() execute.DoBoolAgg

func (*ExactPercentileAgg) NewFloatAgg added in v0.0.5 

func (a *ExactPercentileAgg) NewFloatAgg() execute.DoFloatAgg

func (*ExactPercentileAgg) NewIntAgg added in v0.0.5 

func (a *ExactPercentileAgg) NewIntAgg() execute.DoIntAgg

func (*ExactPercentileAgg) NewStringAgg added in v0.0.5 

func (a *ExactPercentileAgg) NewStringAgg() execute.DoStringAgg

func (*ExactPercentileAgg) NewUIntAgg added in v0.0.5 

func (a *ExactPercentileAgg) NewUIntAgg() execute.DoUIntAgg

func (*ExactPercentileAgg) Type added in v0.0.5 

func (a *ExactPercentileAgg) Type() execute.DataType

func (*ExactPercentileAgg) ValueFloat added in v0.0.5 

func (a *ExactPercentileAgg) ValueFloat() float64

type ExactPercentileProcedureSpec added in v0.0.5 

type ExactPercentileProcedureSpec struct {
	Percentile float64 `json:"percentile"`
}

func (*ExactPercentileProcedureSpec) Copy added in v0.0.5 

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

func (*ExactPercentileProcedureSpec) Kind added in v0.0.5 

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

type FilterOpSpec added in v0.0.2 

type FilterOpSpec struct {
	Fn *semantic.FunctionExpression `json:"fn"`
}

func (*FilterOpSpec) Kind added in v0.0.2 

func (s *FilterOpSpec) Kind() query.OperationKind

type FilterProcedureSpec added in v0.0.2 

type FilterProcedureSpec struct {
	Fn *semantic.FunctionExpression
}

func (*FilterProcedureSpec) Copy added in v0.0.2 

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

func (*FilterProcedureSpec) Kind added in v0.0.2 

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

func (*FilterProcedureSpec) PushDown added in v0.0.2 

func (s *FilterProcedureSpec) PushDown(root *plan.Procedure, dup func() *plan.Procedure)

func (*FilterProcedureSpec) PushDownRules added in v0.0.4 

func (s *FilterProcedureSpec) PushDownRules() []plan.PushDownRule

type FirstOpSpec 

type FirstOpSpec struct {
	Column     string `json:"column"`
	UseRowTime bool   `json:"useRowtime"`
}

func (*FirstOpSpec) Kind 

func (s *FirstOpSpec) Kind() query.OperationKind

type FirstProcedureSpec 

type FirstProcedureSpec struct {
	Column     string
	UseRowTime bool
}

func (*FirstProcedureSpec) Copy 

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

func (*FirstProcedureSpec) Kind 

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

func (*FirstProcedureSpec) PushDown 

func (s *FirstProcedureSpec) PushDown(root *plan.Procedure, dup func() *plan.Procedure)

func (*FirstProcedureSpec) PushDownRules added in v0.0.4 

func (s *FirstProcedureSpec) PushDownRules() []plan.PushDownRule

type FirstSelector 

type FirstSelector struct {
	// contains filtered or unexported fields
}

func (*FirstSelector) DoBool 

func (s *FirstSelector) DoBool(vs []bool) []int

func (*FirstSelector) DoFloat 

func (s *FirstSelector) DoFloat(vs []float64) []int

func (*FirstSelector) DoInt 

func (s *FirstSelector) DoInt(vs []int64) []int

func (*FirstSelector) DoString 

func (s *FirstSelector) DoString(vs []string) []int

func (*FirstSelector) DoUInt 

func (s *FirstSelector) DoUInt(vs []uint64) []int

func (*FirstSelector) NewBoolSelector 

func (s *FirstSelector) NewBoolSelector() execute.DoBoolIndexSelector

func (*FirstSelector) NewFloatSelector 

func (s *FirstSelector) NewFloatSelector() execute.DoFloatIndexSelector

func (*FirstSelector) NewIntSelector 

func (s *FirstSelector) NewIntSelector() execute.DoIntIndexSelector

func (*FirstSelector) NewStringSelector 

func (s *FirstSelector) NewStringSelector() execute.DoStringIndexSelector

func (*FirstSelector) NewUIntSelector 

func (s *FirstSelector) NewUIntSelector() execute.DoUIntIndexSelector

type FromOpSpec added in v0.0.2 

type FromOpSpec struct {
	Database string   `json:"database"`
	Hosts    []string `json:"hosts"`
}

func (*FromOpSpec) Kind added in v0.0.2 

func (s *FromOpSpec) Kind() query.OperationKind

type FromProcedureSpec added in v0.0.2 

type FromProcedureSpec struct {
	Database string
	Hosts    []string

	BoundsSet bool
	Bounds    plan.BoundsSpec

	FilterSet bool
	Filter    *semantic.FunctionExpression

	DescendingSet bool
	Descending    bool

	LimitSet     bool
	PointsLimit  int64
	SeriesLimit  int64
	SeriesOffset int64

	WindowSet bool
	Window    plan.WindowSpec

	GroupingSet bool
	OrderByTime bool
	MergeAll    bool
	GroupKeys   []string
	GroupExcept []string
	GroupKeep   []string

	AggregateSet    bool
	AggregateMethod string
}

func (*FromProcedureSpec) Copy added in v0.0.2 

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

func (*FromProcedureSpec) Kind added in v0.0.2 

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

func (*FromProcedureSpec) TimeBounds added in v0.0.2 

func (s *FromProcedureSpec) TimeBounds() plan.BoundsSpec

type GroupOpSpec 

type GroupOpSpec struct {
	By     []string `json:"by"`
	Keep   []string `json:"keep"`
	Except []string `json:"except"`
}

func (*GroupOpSpec) Kind 

func (s *GroupOpSpec) Kind() query.OperationKind

type GroupProcedureSpec 

type GroupProcedureSpec struct {
	By     []string
	Except []string
	Keep   []string
}

func (*GroupProcedureSpec) Copy 

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

func (*GroupProcedureSpec) Kind 

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

func (*GroupProcedureSpec) PushDown 

func (s *GroupProcedureSpec) PushDown(root *plan.Procedure, dup func() *plan.Procedure)

func (*GroupProcedureSpec) PushDownRules added in v0.0.4 

func (s *GroupProcedureSpec) PushDownRules() []plan.PushDownRule

type IntegralOpSpec added in v0.0.4 

type IntegralOpSpec struct {
	Unit query.Duration `json:"unit"`
}

func (*IntegralOpSpec) Kind added in v0.0.4 

func (s *IntegralOpSpec) Kind() query.OperationKind

type IntegralProcedureSpec added in v0.0.4 

type IntegralProcedureSpec struct {
	Unit query.Duration `json:"unit"`
}

func (*IntegralProcedureSpec) Copy added in v0.0.4 

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

func (*IntegralProcedureSpec) Kind added in v0.0.4 

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

type JoinOpSpec 

type JoinOpSpec struct {
	// On is a list of tags on which to join.
	On []string `json:"on"`
	// Fn is a function accepting a single parameter.
	// The parameter is map if records for each of the parent operations.
	Fn *semantic.FunctionExpression `json:"fn"`
	// TableNames are the names to give to each parent when populating the parameter for the function.
	// The first parent is referenced by the first name and so forth.
	// TODO(nathanielc): Change this to a map of parent operation IDs to names.
	// Then make it possible for the transformation to map operation IDs to parent IDs.
	TableNames map[query.OperationID]string `json:"table_names"`
}

func (*JoinOpSpec) Kind 

func (s *JoinOpSpec) Kind() query.OperationKind

type LastOpSpec 

type LastOpSpec struct {
	Column     string `json:"column"`
	UseRowTime bool   `json:"useRowtime"`
}

func (*LastOpSpec) Kind 

func (s *LastOpSpec) Kind() query.OperationKind

type LastProcedureSpec 

type LastProcedureSpec struct {
	Column     string
	UseRowTime bool
}

func (*LastProcedureSpec) Copy 

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

func (*LastProcedureSpec) Kind 

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

func (*LastProcedureSpec) PushDown 

func (s *LastProcedureSpec) PushDown(root *plan.Procedure, dup func() *plan.Procedure)

func (*LastProcedureSpec) PushDownRules added in v0.0.4 

func (s *LastProcedureSpec) PushDownRules() []plan.PushDownRule

type LastSelector 

type LastSelector struct {
	// contains filtered or unexported fields
}

func (*LastSelector) DoBool 

func (s *LastSelector) DoBool(vs []bool, rr execute.RowReader)

func (*LastSelector) DoFloat 

func (s *LastSelector) DoFloat(vs []float64, rr execute.RowReader)

func (*LastSelector) DoInt 

func (s *LastSelector) DoInt(vs []int64, rr execute.RowReader)

func (*LastSelector) DoString 

func (s *LastSelector) DoString(vs []string, rr execute.RowReader)

func (*LastSelector) DoUInt 

func (s *LastSelector) DoUInt(vs []uint64, rr execute.RowReader)

func (*LastSelector) NewBoolSelector 

func (s *LastSelector) NewBoolSelector() execute.DoBoolRowSelector

func (*LastSelector) NewFloatSelector 

func (s *LastSelector) NewFloatSelector() execute.DoFloatRowSelector

func (*LastSelector) NewIntSelector 

func (s *LastSelector) NewIntSelector() execute.DoIntRowSelector

func (*LastSelector) NewStringSelector 

func (s *LastSelector) NewStringSelector() execute.DoStringRowSelector

func (*LastSelector) NewUIntSelector 

func (s *LastSelector) NewUIntSelector() execute.DoUIntRowSelector

func (*LastSelector) Rows 

func (s *LastSelector) Rows() []execute.Row

type LimitOpSpec 

type LimitOpSpec struct {
	N int64 `json:"n"`
}

LimitOpSpec limits the number of rows returned per block. Currently offset is not supported.

func (*LimitOpSpec) Kind 

func (s *LimitOpSpec) Kind() query.OperationKind

type LimitProcedureSpec 

type LimitProcedureSpec struct {
	N int64 `json:"n"`
}

func (*LimitProcedureSpec) Copy 

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

func (*LimitProcedureSpec) Kind 

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

func (*LimitProcedureSpec) PushDown 

func (s *LimitProcedureSpec) PushDown(root *plan.Procedure, dup func() *plan.Procedure)

func (*LimitProcedureSpec) PushDownRules added in v0.0.4 

func (s *LimitProcedureSpec) PushDownRules() []plan.PushDownRule

type MapOpSpec added in v0.0.4 

type MapOpSpec struct {
	Fn *semantic.FunctionExpression `json:"fn"`
}

func (*MapOpSpec) Kind added in v0.0.4 

func (s *MapOpSpec) Kind() query.OperationKind

type MapProcedureSpec added in v0.0.4 

type MapProcedureSpec struct {
	Fn *semantic.FunctionExpression
}

func (*MapProcedureSpec) Copy added in v0.0.4 

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

func (*MapProcedureSpec) Kind added in v0.0.4 

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

type MaxFloatSelector 

type MaxFloatSelector struct {
	MaxSelector
	// contains filtered or unexported fields
}

func (*MaxFloatSelector) DoFloat 

func (s *MaxFloatSelector) DoFloat(vs []float64, rr execute.RowReader)

type MaxIntSelector 

type MaxIntSelector struct {
	MaxSelector
	// contains filtered or unexported fields
}

func (*MaxIntSelector) DoInt 

func (s *MaxIntSelector) DoInt(vs []int64, rr execute.RowReader)

type MaxOpSpec 

type MaxOpSpec struct {
	Column     string `json:"column"`
	UseRowTime bool   `json:"useRowtime"`
}

func (*MaxOpSpec) Kind 

func (s *MaxOpSpec) Kind() query.OperationKind

type MaxProcedureSpec 

type MaxProcedureSpec struct {
	Column     string
	UseRowTime bool
}

func (*MaxProcedureSpec) Copy 

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

func (*MaxProcedureSpec) Kind 

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

type MaxSelector 

type MaxSelector struct {
	// contains filtered or unexported fields
}

func (*MaxSelector) NewBoolSelector 

func (s *MaxSelector) NewBoolSelector() execute.DoBoolRowSelector

func (*MaxSelector) NewFloatSelector 

func (s *MaxSelector) NewFloatSelector() execute.DoFloatRowSelector

func (*MaxSelector) NewIntSelector 

func (s *MaxSelector) NewIntSelector() execute.DoIntRowSelector

func (*MaxSelector) NewStringSelector 

func (s *MaxSelector) NewStringSelector() execute.DoStringRowSelector

func (*MaxSelector) NewUIntSelector 

func (s *MaxSelector) NewUIntSelector() execute.DoUIntRowSelector

func (*MaxSelector) Rows 

func (s *MaxSelector) Rows() []execute.Row

type MaxUIntSelector 

type MaxUIntSelector struct {
	MaxSelector
	// contains filtered or unexported fields
}

func (*MaxUIntSelector) DoUInt 

func (s *MaxUIntSelector) DoUInt(vs []uint64, rr execute.RowReader)

type MeanAgg 

type MeanAgg struct {
	// contains filtered or unexported fields
}

func (*MeanAgg) DoFloat 

func (a *MeanAgg) DoFloat(vs []float64)

func (*MeanAgg) DoInt 

func (a *MeanAgg) DoInt(vs []int64)

func (*MeanAgg) DoUInt 

func (a *MeanAgg) DoUInt(vs []uint64)

func (*MeanAgg) NewBoolAgg 

func (a *MeanAgg) NewBoolAgg() execute.DoBoolAgg

func (*MeanAgg) NewFloatAgg 

func (a *MeanAgg) NewFloatAgg() execute.DoFloatAgg

func (*MeanAgg) NewIntAgg 

func (a *MeanAgg) NewIntAgg() execute.DoIntAgg

func (*MeanAgg) NewStringAgg 

func (a *MeanAgg) NewStringAgg() execute.DoStringAgg

func (*MeanAgg) NewUIntAgg 

func (a *MeanAgg) NewUIntAgg() execute.DoUIntAgg

func (*MeanAgg) Type 

func (a *MeanAgg) Type() execute.DataType

func (*MeanAgg) ValueFloat 

func (a *MeanAgg) ValueFloat() float64

type MeanOpSpec 

type MeanOpSpec struct {
}

func (*MeanOpSpec) Kind 

func (s *MeanOpSpec) Kind() query.OperationKind

type MeanProcedureSpec 

type MeanProcedureSpec struct {
}

func (*MeanProcedureSpec) Copy 

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

func (*MeanProcedureSpec) Kind 

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

type MergeJoinCache 

type MergeJoinCache interface {
	Tables(execute.BlockMetadata) *joinTables
}

type MergeJoinProcedureSpec 

type MergeJoinProcedureSpec struct {
	On         []string                     `json:"keys"`
	Fn         *semantic.FunctionExpression `json:"f"`
	TableNames map[plan.ProcedureID]string  `json:"table_names"`
}

func (*MergeJoinProcedureSpec) Copy 

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

func (*MergeJoinProcedureSpec) Kind 

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

func (*MergeJoinProcedureSpec) ParentChanged added in v0.0.4 

func (s *MergeJoinProcedureSpec) ParentChanged(old, new plan.ProcedureID)

type MinFloatSelector 

type MinFloatSelector struct {
	MinSelector
	// contains filtered or unexported fields
}

func (*MinFloatSelector) DoFloat 

func (s *MinFloatSelector) DoFloat(vs []float64, rr execute.RowReader)

type MinIntSelector 

type MinIntSelector struct {
	MinSelector
	// contains filtered or unexported fields
}

func (*MinIntSelector) DoInt 

func (s *MinIntSelector) DoInt(vs []int64, rr execute.RowReader)

type MinOpSpec 

type MinOpSpec struct {
	Column     string `json:"column"`
	UseRowTime bool   `json:"useRowtime"`
}

func (*MinOpSpec) Kind 

func (s *MinOpSpec) Kind() query.OperationKind

type MinProcedureSpec 

type MinProcedureSpec struct {
	Column     string
	UseRowTime bool
}

func (*MinProcedureSpec) Copy 

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

func (*MinProcedureSpec) Kind 

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

type MinSelector 

type MinSelector struct {
	// contains filtered or unexported fields
}

func (*MinSelector) NewBoolSelector 

func (s *MinSelector) NewBoolSelector() execute.DoBoolRowSelector

func (*MinSelector) NewFloatSelector 

func (s *MinSelector) NewFloatSelector() execute.DoFloatRowSelector

func (*MinSelector) NewIntSelector 

func (s *MinSelector) NewIntSelector() execute.DoIntRowSelector

func (*MinSelector) NewStringSelector 

func (s *MinSelector) NewStringSelector() execute.DoStringRowSelector

func (*MinSelector) NewUIntSelector 

func (s *MinSelector) NewUIntSelector() execute.DoUIntRowSelector

func (*MinSelector) Rows 

func (s *MinSelector) Rows() []execute.Row

type MinUIntSelector 

type MinUIntSelector struct {
	MinSelector
	// contains filtered or unexported fields
}

func (*MinUIntSelector) DoUInt 

func (s *MinUIntSelector) DoUInt(vs []uint64, rr execute.RowReader)

type PercentileAgg added in v0.0.5 

type PercentileAgg struct {
	Quantile,
	Compression float64
	// contains filtered or unexported fields
}

func (*PercentileAgg) DoFloat added in v0.0.5 

func (a *PercentileAgg) DoFloat(vs []float64)

func (*PercentileAgg) NewBoolAgg added in v0.0.5 

func (a *PercentileAgg) NewBoolAgg() execute.DoBoolAgg

func (*PercentileAgg) NewFloatAgg added in v0.0.5 

func (a *PercentileAgg) NewFloatAgg() execute.DoFloatAgg

func (*PercentileAgg) NewIntAgg added in v0.0.5 

func (a *PercentileAgg) NewIntAgg() execute.DoIntAgg

func (*PercentileAgg) NewStringAgg added in v0.0.5 

func (a *PercentileAgg) NewStringAgg() execute.DoStringAgg

func (*PercentileAgg) NewUIntAgg added in v0.0.5 

func (a *PercentileAgg) NewUIntAgg() execute.DoUIntAgg

func (*PercentileAgg) Type added in v0.0.5 

func (a *PercentileAgg) Type() execute.DataType

func (*PercentileAgg) ValueFloat added in v0.0.5 

func (a *PercentileAgg) ValueFloat() float64

type PercentileOpSpec added in v0.0.5 

type PercentileOpSpec struct {
	Percentile  float64 `json:"percentile"`
	Compression float64 `json:"compression"`
	Exact       bool    `json:"exact"`
}

func (*PercentileOpSpec) Kind added in v0.0.5 

func (s *PercentileOpSpec) Kind() query.OperationKind

type PercentileProcedureSpec added in v0.0.5 

type PercentileProcedureSpec struct {
	Percentile  float64 `json:"percentile"`
	Compression float64 `json:"compression"`
}

func (*PercentileProcedureSpec) Copy added in v0.0.5 

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

func (*PercentileProcedureSpec) Kind added in v0.0.5 

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

type RangeOpSpec 

type RangeOpSpec struct {
	Start query.Time `json:"start"`
	Stop  query.Time `json:"stop"`
}

func (*RangeOpSpec) Kind 

func (s *RangeOpSpec) Kind() query.OperationKind

type RangeProcedureSpec 

type RangeProcedureSpec struct {
	Bounds plan.BoundsSpec
}

func (*RangeProcedureSpec) Copy 

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

func (*RangeProcedureSpec) Kind 

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

func (*RangeProcedureSpec) PushDown 

func (s *RangeProcedureSpec) PushDown(root *plan.Procedure, dup func() *plan.Procedure)

func (*RangeProcedureSpec) PushDownRules added in v0.0.4 

func (s *RangeProcedureSpec) PushDownRules() []plan.PushDownRule

func (*RangeProcedureSpec) TimeBounds 

func (s *RangeProcedureSpec) TimeBounds() plan.BoundsSpec

type SampleOpSpec 

type SampleOpSpec struct {
	Column     string `json:"column"`
	UseRowTime bool   `json:"useRowtime"`
	N          int64  `json:"n"`
	Pos        int64  `json:"pos"`
}

func (*SampleOpSpec) Kind 

func (s *SampleOpSpec) Kind() query.OperationKind

type SampleProcedureSpec 

type SampleProcedureSpec struct {
	Column     string
	UseRowTime bool
	N          int64
	Pos        int64
}

func (*SampleProcedureSpec) Copy 

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

func (*SampleProcedureSpec) Kind 

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

type SampleSelector 

type SampleSelector struct {
	N   int
	Pos int
	// contains filtered or unexported fields
}

func (*SampleSelector) DoBool 

func (s *SampleSelector) DoBool(vs []bool) []int

func (*SampleSelector) DoFloat 

func (s *SampleSelector) DoFloat(vs []float64) []int

func (*SampleSelector) DoInt 

func (s *SampleSelector) DoInt(vs []int64) []int

func (*SampleSelector) DoString 

func (s *SampleSelector) DoString(vs []string) []int

func (*SampleSelector) DoUInt 

func (s *SampleSelector) DoUInt(vs []uint64) []int

func (*SampleSelector) NewBoolSelector 

func (s *SampleSelector) NewBoolSelector() execute.DoBoolIndexSelector

func (*SampleSelector) NewFloatSelector 

func (s *SampleSelector) NewFloatSelector() execute.DoFloatIndexSelector

func (*SampleSelector) NewIntSelector 

func (s *SampleSelector) NewIntSelector() execute.DoIntIndexSelector

func (*SampleSelector) NewStringSelector 

func (s *SampleSelector) NewStringSelector() execute.DoStringIndexSelector

func (*SampleSelector) NewUIntSelector 

func (s *SampleSelector) NewUIntSelector() execute.DoUIntIndexSelector

type SetOpSpec 

type SetOpSpec struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}

func (*SetOpSpec) Kind 

func (s *SetOpSpec) Kind() query.OperationKind

type SetProcedureSpec 

type SetProcedureSpec struct {
	Key, Value string
}

func (*SetProcedureSpec) Copy 

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

func (*SetProcedureSpec) Kind 

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

type ShiftOpSpec added in v0.0.4 

type ShiftOpSpec struct {
	Shift query.Duration `json:"shift"`
}

func (*ShiftOpSpec) Kind added in v0.0.4 

func (s *ShiftOpSpec) Kind() query.OperationKind

type ShiftProcedureSpec added in v0.0.4 

type ShiftProcedureSpec struct {
	Shift query.Duration
}

func (*ShiftProcedureSpec) Copy added in v0.0.4 

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

func (*ShiftProcedureSpec) Kind added in v0.0.4 

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

type SkewAgg 

type SkewAgg struct {
	// contains filtered or unexported fields
}

func (*SkewAgg) DoFloat 

func (a *SkewAgg) DoFloat(vs []float64)

func (*SkewAgg) DoInt 

func (a *SkewAgg) DoInt(vs []int64)

func (*SkewAgg) DoUInt 

func (a *SkewAgg) DoUInt(vs []uint64)

func (*SkewAgg) NewBoolAgg 

func (a *SkewAgg) NewBoolAgg() execute.DoBoolAgg

func (*SkewAgg) NewFloatAgg 

func (a *SkewAgg) NewFloatAgg() execute.DoFloatAgg

func (*SkewAgg) NewIntAgg 

func (a *SkewAgg) NewIntAgg() execute.DoIntAgg

func (*SkewAgg) NewStringAgg 

func (a *SkewAgg) NewStringAgg() execute.DoStringAgg

func (*SkewAgg) NewUIntAgg 

func (a *SkewAgg) NewUIntAgg() execute.DoUIntAgg

func (*SkewAgg) Type 

func (a *SkewAgg) Type() execute.DataType

func (*SkewAgg) ValueFloat 

func (a *SkewAgg) ValueFloat() float64

type SkewOpSpec 

type SkewOpSpec struct {
}

func (*SkewOpSpec) Kind 

func (s *SkewOpSpec) Kind() query.OperationKind

type SkewProcedureSpec 

type SkewProcedureSpec struct {
}

func (*SkewProcedureSpec) Copy 

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

func (*SkewProcedureSpec) Kind 

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

type SortOpSpec 

type SortOpSpec struct {
	Cols []string `json:"cols"`
	Desc bool     `json:"desc"`
}

func (*SortOpSpec) Kind 

func (s *SortOpSpec) Kind() query.OperationKind

type SortProcedureSpec 

type SortProcedureSpec struct {
	Cols []string
	Desc bool
}

func (*SortProcedureSpec) Copy 

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

func (*SortProcedureSpec) Kind 

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

type SpreadAgg 

type SpreadAgg struct {
	// contains filtered or unexported fields
}

SpreadAgg finds the difference between the max and min values a block

func (*SpreadAgg) NewBoolAgg 

func (a *SpreadAgg) NewBoolAgg() execute.DoBoolAgg

func (*SpreadAgg) NewFloatAgg 

func (a *SpreadAgg) NewFloatAgg() execute.DoFloatAgg

func (*SpreadAgg) NewIntAgg 

func (a *SpreadAgg) NewIntAgg() execute.DoIntAgg

func (*SpreadAgg) NewStringAgg 

func (a *SpreadAgg) NewStringAgg() execute.DoStringAgg

func (*SpreadAgg) NewUIntAgg 

func (a *SpreadAgg) NewUIntAgg() execute.DoUIntAgg

type SpreadFloatAgg 

type SpreadFloatAgg struct {
	SpreadAgg
	// contains filtered or unexported fields
}

func (*SpreadFloatAgg) DoFloat 

func (a *SpreadFloatAgg) DoFloat(vs []float64)

Do searches for the min and max value of the array and caches them in the aggregate

func (*SpreadFloatAgg) Type 

func (a *SpreadFloatAgg) Type() execute.DataType

func (*SpreadFloatAgg) ValueFloat 

func (a *SpreadFloatAgg) ValueFloat() float64

Value returns the difference between max and min

type SpreadIntAgg 

type SpreadIntAgg struct {
	SpreadAgg
	// contains filtered or unexported fields
}

func (*SpreadIntAgg) DoInt 

func (a *SpreadIntAgg) DoInt(vs []int64)

DoInt searches for the min and max value of the array and caches them in the aggregate

func (*SpreadIntAgg) Type 

func (a *SpreadIntAgg) Type() execute.DataType

func (*SpreadIntAgg) ValueInt 

func (a *SpreadIntAgg) ValueInt() int64

Value returns the difference between max and min

type SpreadOpSpec 

type SpreadOpSpec struct{}

SpreadOpSpec defines the required arguments for IFQL. Currently, spread takes no arguments.

func (*SpreadOpSpec) Kind 

func (s *SpreadOpSpec) Kind() query.OperationKind

Kind is used to lookup createSpreadOpSpec producing SpreadOpSpec

type SpreadProcedureSpec 

type SpreadProcedureSpec struct{}

SpreadProcedureSpec is created when mapping from SpreadOpSpec.Kind to a CreateProcedureSpec.

func (*SpreadProcedureSpec) Copy 

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

func (*SpreadProcedureSpec) Kind 

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

Kind is used to lookup CreateTransformation producing SpreadAgg

type SpreadUIntAgg 

type SpreadUIntAgg struct {
	SpreadAgg
	// contains filtered or unexported fields
}

func (*SpreadUIntAgg) DoUInt 

func (a *SpreadUIntAgg) DoUInt(vs []uint64)

Do searches for the min and max value of the array and caches them in the aggregate

func (*SpreadUIntAgg) Type 

func (a *SpreadUIntAgg) Type() execute.DataType

func (*SpreadUIntAgg) ValueUInt 

func (a *SpreadUIntAgg) ValueUInt() uint64

Value returns the difference between max and min

type StateTrackingOpSpec added in v0.0.5 

type StateTrackingOpSpec struct {
	Fn            *semantic.FunctionExpression `json:"fn"`
	CountLabel    string                       `json:"count_label"`
	DurationLabel string                       `json:"duration_label"`
	DurationUnit  query.Duration               `json:"duration_unit"`
}

func (*StateTrackingOpSpec) Kind added in v0.0.5 

func (s *StateTrackingOpSpec) Kind() query.OperationKind

type StateTrackingProcedureSpec added in v0.0.5 

type StateTrackingProcedureSpec struct {
	Fn *semantic.FunctionExpression
	CountLabel,
	DurationLabel string
	DurationUnit query.Duration
}

func (*StateTrackingProcedureSpec) Copy added in v0.0.5 

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

func (*StateTrackingProcedureSpec) Kind added in v0.0.5 

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

type StddevAgg 

type StddevAgg struct {
	// contains filtered or unexported fields
}

func (*StddevAgg) DoFloat 

func (a *StddevAgg) DoFloat(vs []float64)

func (*StddevAgg) DoInt 

func (a *StddevAgg) DoInt(vs []int64)

func (*StddevAgg) DoUInt 

func (a *StddevAgg) DoUInt(vs []uint64)

func (*StddevAgg) NewBoolAgg 

func (a *StddevAgg) NewBoolAgg() execute.DoBoolAgg

func (*StddevAgg) NewFloatAgg 

func (a *StddevAgg) NewFloatAgg() execute.DoFloatAgg

func (*StddevAgg) NewIntAgg 

func (a *StddevAgg) NewIntAgg() execute.DoIntAgg

func (*StddevAgg) NewStringAgg 

func (a *StddevAgg) NewStringAgg() execute.DoStringAgg

func (*StddevAgg) NewUIntAgg 

func (a *StddevAgg) NewUIntAgg() execute.DoUIntAgg

func (*StddevAgg) Type 

func (a *StddevAgg) Type() execute.DataType

func (*StddevAgg) ValueFloat 

func (a *StddevAgg) ValueFloat() float64

type StddevOpSpec 

type StddevOpSpec struct {
}

func (*StddevOpSpec) Kind 

func (s *StddevOpSpec) Kind() query.OperationKind

type StddevProcedureSpec 

type StddevProcedureSpec struct {
}

func (*StddevProcedureSpec) Copy 

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

func (*StddevProcedureSpec) Kind 

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

type SumAgg 

type SumAgg struct{}

func (*SumAgg) NewBoolAgg 

func (a *SumAgg) NewBoolAgg() execute.DoBoolAgg

func (*SumAgg) NewFloatAgg 

func (a *SumAgg) NewFloatAgg() execute.DoFloatAgg

func (*SumAgg) NewIntAgg 

func (a *SumAgg) NewIntAgg() execute.DoIntAgg

func (*SumAgg) NewStringAgg 

func (a *SumAgg) NewStringAgg() execute.DoStringAgg

func (*SumAgg) NewUIntAgg 

func (a *SumAgg) NewUIntAgg() execute.DoUIntAgg

type SumFloatAgg 

type SumFloatAgg struct {
	// contains filtered or unexported fields
}

func (*SumFloatAgg) DoFloat 

func (a *SumFloatAgg) DoFloat(vs []float64)

func (*SumFloatAgg) Type 

func (a *SumFloatAgg) Type() execute.DataType

func (*SumFloatAgg) ValueFloat 

func (a *SumFloatAgg) ValueFloat() float64

type SumIntAgg 

type SumIntAgg struct {
	// contains filtered or unexported fields
}

func (*SumIntAgg) DoInt 

func (a *SumIntAgg) DoInt(vs []int64)

func (*SumIntAgg) Type 

func (a *SumIntAgg) Type() execute.DataType

func (*SumIntAgg) ValueInt 

func (a *SumIntAgg) ValueInt() int64

type SumOpSpec 

type SumOpSpec struct {
}

func (*SumOpSpec) Kind 

func (s *SumOpSpec) Kind() query.OperationKind

type SumProcedureSpec 

type SumProcedureSpec struct {
}

func (*SumProcedureSpec) AggregateMethod added in v0.0.5 

func (s *SumProcedureSpec) AggregateMethod() string

func (*SumProcedureSpec) Copy 

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

func (*SumProcedureSpec) Kind 

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

func (*SumProcedureSpec) PushDown 

func (s *SumProcedureSpec) PushDown(root *plan.Procedure, dup func() *plan.Procedure)

func (*SumProcedureSpec) PushDownRules added in v0.0.4 

func (s *SumProcedureSpec) PushDownRules() []plan.PushDownRule

func (*SumProcedureSpec) ReAggregateSpec added in v0.0.5 

func (s *SumProcedureSpec) ReAggregateSpec() plan.ProcedureSpec

type SumUIntAgg 

type SumUIntAgg struct {
	// contains filtered or unexported fields
}

func (*SumUIntAgg) DoUInt 

func (a *SumUIntAgg) DoUInt(vs []uint64)

func (*SumUIntAgg) Type 

func (a *SumUIntAgg) Type() execute.DataType

func (*SumUIntAgg) ValueUInt 

func (a *SumUIntAgg) ValueUInt() uint64

type WindowOpSpec 

type WindowOpSpec struct {
	Every      query.Duration    `json:"every"`
	Period     query.Duration    `json:"period"`
	Start      query.Time        `json:"start"`
	Round      query.Duration    `json:"round"`
	Triggering query.TriggerSpec `json:"triggering"`
}

func (*WindowOpSpec) Kind 

func (s *WindowOpSpec) Kind() query.OperationKind

type WindowProcedureSpec 

type WindowProcedureSpec struct {
	Window     plan.WindowSpec
	Triggering query.TriggerSpec
}

func (*WindowProcedureSpec) Copy 

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

func (*WindowProcedureSpec) Kind 

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

func (*WindowProcedureSpec) TriggerSpec 

func (s *WindowProcedureSpec) TriggerSpec() query.TriggerSpec

type YieldOpSpec added in v0.0.5 

type YieldOpSpec struct {
	Name string `json:"name"`
}

func (*YieldOpSpec) Kind added in v0.0.5 

func (s *YieldOpSpec) Kind() query.OperationKind

type YieldProcedureSpec added in v0.0.5 

type YieldProcedureSpec struct {
	Name string `json:"name"`
}

func (*YieldProcedureSpec) Copy added in v0.0.5 

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

func (*YieldProcedureSpec) Kind added in v0.0.5 

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

func (*YieldProcedureSpec) YieldName added in v0.0.5 

func (s *YieldProcedureSpec) YieldName() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.