Documentation ¶
Index ¶
- func At(left, right ast.Node) ast.Node
- func Dot(left, right ast.Node) ast.Node
- func Func(name string, args ...interface{}) (ast.Node, error)
- func FuncWithZero(name string, args ...interface{}) (ast.Node, error)
- func IsZero(arg interface{}) bool
- func Literal(lit interface{}) (ast.Node, error)
- func Pipe(left, right ast.Node) ast.Node
- type AST
- type AlertNode
- type BarrierNode
- type BatchNode
- type CombineNode
- type DefaultNode
- type DeleteNode
- type DerivativeNode
- type Ec2AutoscaleNode
- type EvalNode
- type FlattenNode
- type FromNode
- type Function
- func (f *Function) At(name string, args ...interface{}) *Function
- func (f *Function) Dot(name string, args ...interface{}) *Function
- func (f *Function) DotIf(name string, use bool) *Function
- func (f *Function) DotNotEmpty(name string, arg ...interface{}) *Function
- func (f *Function) DotNotNil(name string, arg interface{}) *Function
- func (f *Function) DotZeroValueOK(name string, args ...interface{}) *Function
- func (f *Function) Pipe(name string, args ...interface{}) *Function
- type GroupByNode
- type HTTPOutNode
- type HTTPPostNode
- type InfluxDBOutNode
- type InfluxQLNode
- type JoinNode
- type K8sAutoscaleNode
- type KapacitorLoopbackNode
- type LogNode
- type NullPosition
- type QueryNode
- type SampleNode
- type ShiftNode
- type SideloadNode
- type StateCountNode
- type StateDurationNode
- type StatsNode
- type StreamNode
- type SwarmAutoscaleNode
- type UDFNode
- type UnionNode
- type WhereNode
- type WindowNode
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Func ¶
Func produces an ast.FunctionNode. Can return a nil Node if all function arguments evaluate to the zero value.
func FuncWithZero ¶
FuncWithZero produces an ast.FunctionNode. All function arguments that evaluate to the zero value are kept.
func IsZero ¶
func IsZero(arg interface{}) bool
IsZero check if the argument is the tickscript zero value for that type.
Types ¶
type AST ¶
type AST struct { Program ast.ProgramNode // contains filtered or unexported fields }
AST converts a pipeline into an AST
type AlertNode ¶
type AlertNode struct {
Function
}
AlertNode converts the Alert pipeline node into the TICKScript AST
type BarrierNode ¶
type BarrierNode struct {
Function
}
BarrierNode converts the window pipeline node into the TICKScript AST
func NewBarrierNode ¶
func NewBarrierNode(parents []ast.Node) *BarrierNode
NewBarrierNode creates a Barrier function builder
func (*BarrierNode) Build ¶
func (n *BarrierNode) Build(b *pipeline.BarrierNode) (ast.Node, error)
Build creates a window ast.Node
type BatchNode ¶
type BatchNode struct{}
BatchNode converts the batch pipeline node into the TICKScript AST
type CombineNode ¶
type CombineNode struct {
Function
}
CombineNode converts the Combine pipeline node into the TICKScript AST
func NewCombine ¶
func NewCombine(parents []ast.Node) *CombineNode
NewCombine creates a Combine function builder
func (*CombineNode) Build ¶
func (n *CombineNode) Build(c *pipeline.CombineNode) (ast.Node, error)
Build creates a Combine ast.Node
type DefaultNode ¶
type DefaultNode struct {
Function
}
DefaultNode converts the Default pipeline node into the TICKScript AST
func NewDefault ¶
func NewDefault(parents []ast.Node) *DefaultNode
NewDefault creates a Default function builder
func (*DefaultNode) Build ¶
func (n *DefaultNode) Build(d *pipeline.DefaultNode) (ast.Node, error)
Build creates a Default ast.Node
type DeleteNode ¶
type DeleteNode struct {
Function
}
DeleteNode converts the Delete pipeline node into the TICKScript AST
func NewDelete ¶
func NewDelete(parents []ast.Node) *DeleteNode
NewDelete creates a Delete function builder
func (*DeleteNode) Build ¶
func (n *DeleteNode) Build(d *pipeline.DeleteNode) (ast.Node, error)
Build creates a Delete ast.Node
type DerivativeNode ¶
type DerivativeNode struct {
Function
}
DerivativeNode converts the Derivative pipeline node into the TICKScript AST
func NewDerivative ¶
func NewDerivative(parents []ast.Node) *DerivativeNode
NewDerivative creates a Derivative function builder
func (*DerivativeNode) Build ¶
func (n *DerivativeNode) Build(d *pipeline.DerivativeNode) (ast.Node, error)
Build creates a Derivative ast.Node
type Ec2AutoscaleNode ¶
type Ec2AutoscaleNode struct {
Function
}
Ec2AutoscaleNode converts the ec2 autoscaling pipeline node into the TICKScript AST
func NewEc2Autoscale ¶
func NewEc2Autoscale(parents []ast.Node) *Ec2AutoscaleNode
NewEc2Autoscale creates a Ec2Autoscale function builder
func (*Ec2AutoscaleNode) Build ¶
func (n *Ec2AutoscaleNode) Build(s *pipeline.Ec2AutoscaleNode) (ast.Node, error)
Build creates a Ec2Autoscale ast.Node
type EvalNode ¶
type EvalNode struct {
Function
}
EvalNode converts the EvalNode pipeline node into the TICKScript AST
type FlattenNode ¶
type FlattenNode struct {
Function
}
FlattenNode converts the FlattenNode pipeline node into the TICKScript AST
func NewFlatten ¶
func NewFlatten(parents []ast.Node) *FlattenNode
NewFlatten creates a FlattenNode function builder
func (*FlattenNode) Build ¶
func (n *FlattenNode) Build(f *pipeline.FlattenNode) (ast.Node, error)
Build creates a Flatten ast.Node
type FromNode ¶
type FromNode struct {
Function
}
FromNode converts the FromNode pipeline node into the TICKScript AST
type Function ¶
Function builds functions from pipeline nodes
func (*Function) At ¶
At produces an ast.FunctionNode within an At Chain. May return the parent node if all args evaluate to the zero value. Assumes there is only one At called per Function. Assumes one parent exists.
func (*Function) Dot ¶
Dot produces an ast.FunctionNode within a Dot Chain. May return a parent node if all args evaluate to the zero value Assumes a previous node has been created.
func (*Function) DotIf ¶
DotIf produces an ast.FunctionNode within a Dot Chain if use is true Assumes a previous node has been created.
func (*Function) DotNotEmpty ¶
DotNotEmpty produces an ast.FunctionNode within a Dot Chain if the argument list is not empty. Assumes a previous node has been created.
func (*Function) DotNotNil ¶
DotNotNil produces an ast.FunctionNode within a Dot Chain if arg is not nil. Assumes a previous node has been created.
func (*Function) DotZeroValueOK ¶
DotZeroValueOK produces an ast.FunctionNode within a Dot Chain. Assumes a previous node has been created.
type GroupByNode ¶
type GroupByNode struct {
Function
}
GroupByNode converts the GroupByNode pipeline node into the TICKScript AST
func NewGroupBy ¶
func NewGroupBy(parents []ast.Node) *GroupByNode
NewGroupBy creates a GroupByNode function builder
func (*GroupByNode) Build ¶
func (n *GroupByNode) Build(g *pipeline.GroupByNode) (ast.Node, error)
Build creates a GroupByNode ast.Node
type HTTPOutNode ¶
type HTTPOutNode struct {
Function
}
HTTPOutNode converts the HTTPOutNode pipeline node into the TICKScript AST
func NewHTTPOut ¶
func NewHTTPOut(parents []ast.Node) *HTTPOutNode
NewHTTPOut creates a HTTPOutNode function builder
func (*HTTPOutNode) Build ¶
func (n *HTTPOutNode) Build(h *pipeline.HTTPOutNode) (ast.Node, error)
Build creates a HTTPOutNode ast.Node
type HTTPPostNode ¶
type HTTPPostNode struct {
Function
}
HTTPPostNode converts the HTTPPostNode pipeline node into the TICKScript AST
func NewHTTPPost ¶
func NewHTTPPost(parents []ast.Node) *HTTPPostNode
NewHTTPPost creates a HTTPPostNode function builder
func (*HTTPPostNode) Build ¶
func (n *HTTPPostNode) Build(h *pipeline.HTTPPostNode) (ast.Node, error)
Build creates a HTTPPostNode ast.Node
type InfluxDBOutNode ¶
type InfluxDBOutNode struct {
Function
}
InfluxDBOutNode converts the InfluxDBOutNode pipeline node into the TICKScript AST
func NewInfluxDBOut ¶
func NewInfluxDBOut(parents []ast.Node) *InfluxDBOutNode
NewInfluxDBOut creates a InfluxQL function builder
func (*InfluxDBOutNode) Build ¶
func (n *InfluxDBOutNode) Build(db *pipeline.InfluxDBOutNode) (ast.Node, error)
Build creates a InfluxDBOutNode ast.Node
type InfluxQLNode ¶
type InfluxQLNode struct {
Function
}
InfluxQLNode converts the InfluxQLNode pipeline node into the TICKScript AST
func NewInfluxQL ¶
func NewInfluxQL(parents []ast.Node) *InfluxQLNode
NewInfluxQL creates a InfluxQLNode function builder
func (*InfluxQLNode) Build ¶
func (n *InfluxQLNode) Build(q *pipeline.InfluxQLNode) (ast.Node, error)
Build creates a InfluxQLNode ast.Node
type JoinNode ¶
type JoinNode struct {
Function
}
JoinNode converts the JoinNode pipeline node into the TICKScript AST
type K8sAutoscaleNode ¶
type K8sAutoscaleNode struct {
Function
}
K8sAutoscaleNode converts the K8sAutoscaleNode pipeline node into the TICKScript AST
func NewK8sAutoscale ¶
func NewK8sAutoscale(parents []ast.Node) *K8sAutoscaleNode
NewK8sAutoscale creates a K8sAutoscaleNode function builder
func (*K8sAutoscaleNode) Build ¶
func (n *K8sAutoscaleNode) Build(k *pipeline.K8sAutoscaleNode) (ast.Node, error)
Build creates a K8sAutoscaleNode ast.Node
type KapacitorLoopbackNode ¶
type KapacitorLoopbackNode struct {
Function
}
KapacitorLoopbackNode converts the KapacitorLoopbackNode pipeline node into the TICKScript AST
func NewKapacitorLoopbackNode ¶
func NewKapacitorLoopbackNode(parents []ast.Node) *KapacitorLoopbackNode
NewKapacitorLoopbackNode creates a KapacitorLoopbackNode function builder
func (*KapacitorLoopbackNode) Build ¶
func (n *KapacitorLoopbackNode) Build(k *pipeline.KapacitorLoopbackNode) (ast.Node, error)
Build creates a KapacitorLoopbackNode ast.Node
type LogNode ¶
type LogNode struct {
Function
}
LogNode converts the LogNode pipeline node into the TICKScript AST
type NullPosition ¶
type NullPosition struct{}
NullPosition is a NOOP to satisfy the tick AST package
type QueryNode ¶
type QueryNode struct {
Function
}
QueryNode converts the QueryNode pipeline node into the TICKScript AST
type SampleNode ¶
type SampleNode struct {
Function
}
SampleNode converts the SampleNode pipeline node into the TICKScript AST
func NewSample ¶
func NewSample(parents []ast.Node) *SampleNode
NewSample creates a SampleNode function builder
func (*SampleNode) Build ¶
func (n *SampleNode) Build(s *pipeline.SampleNode) (ast.Node, error)
Build creates a SampleNode ast.Node
type ShiftNode ¶
type ShiftNode struct {
Function
}
ShiftNode converts the ShiftNode pipeline node into the TICKScript AST
type SideloadNode ¶
type SideloadNode struct {
Function
}
SideloadNode converts the Sideload pipeline node into the TICKScript AST
func NewSideload ¶
func NewSideload(parents []ast.Node) *SideloadNode
NewSideload creates a Sideload function builder
func (*SideloadNode) Build ¶
func (n *SideloadNode) Build(d *pipeline.SideloadNode) (ast.Node, error)
Build creates a Sideload ast.Node
type StateCountNode ¶
type StateCountNode struct {
Function
}
StateCountNode converts the StateCountNode pipeline node into the TICKScript AST
func NewStateCount ¶
func NewStateCount(parents []ast.Node) *StateCountNode
NewStateCount creates a StateCountNode function builder
func (*StateCountNode) Build ¶
func (n *StateCountNode) Build(s *pipeline.StateCountNode) (ast.Node, error)
Build creates a StateCountNode ast.Node
type StateDurationNode ¶
type StateDurationNode struct {
Function
}
StateDurationNode converts the StateDurationNode pipeline node into the TICKScript AST
func NewStateDuration ¶
func NewStateDuration(parents []ast.Node) *StateDurationNode
NewStateDuration creates a StateDurationNode function builder
func (*StateDurationNode) Build ¶
func (n *StateDurationNode) Build(s *pipeline.StateDurationNode) (ast.Node, error)
Build creates a StateDurationNode ast.Node
type StatsNode ¶
type StatsNode struct {
Function
}
StatsNode converts the StatsNode pipeline node into the TICKScript AST
type StreamNode ¶
type StreamNode struct{}
StreamNode converts the stream pipeline node into the TICKScript AST
type SwarmAutoscaleNode ¶
type SwarmAutoscaleNode struct {
Function
}
SwarmAutoscaleNode converts the swarm autoscaling pipeline node into the TICKScript AST
func NewSwarmAutoscale ¶
func NewSwarmAutoscale(parents []ast.Node) *SwarmAutoscaleNode
NewSwarmAutoscale creates a SwarmAutoscale function builder
func (*SwarmAutoscaleNode) Build ¶
func (n *SwarmAutoscaleNode) Build(s *pipeline.SwarmAutoscaleNode) (ast.Node, error)
Build creates a SwarmAutoscale ast.Node
type UDFNode ¶
type UDFNode struct {
Function
}
UDFNode converts the UDF pipeline node into the TICKScript AST
type UnionNode ¶
type UnionNode struct {
Function
}
UnionNode converts the union pipeline node into the TICKScript AST
type WhereNode ¶
type WhereNode struct {
Function
}
WhereNode converts the where pipeline node into the TICKScript AST
type WindowNode ¶
type WindowNode struct {
Function
}
WindowNode converts the window pipeline node into the TICKScript AST
func NewWindowNode ¶
func NewWindowNode(parents []ast.Node) *WindowNode
NewWindowNode creates a Window function builder
func (*WindowNode) Build ¶
func (n *WindowNode) Build(w *pipeline.WindowNode) (ast.Node, error)
Build creates a window ast.Node
Source Files ¶
- alert.go
- ast.go
- barrier.go
- batch.go
- combine.go
- default.go
- delete.go
- derivative.go
- ec2_autoscale.go
- eval.go
- flatten.go
- from.go
- function.go
- group_by.go
- http_out.go
- http_post.go
- influx.go
- influxdb_out.go
- join.go
- k8s_autoscale.go
- kapacitor_loopback.go
- log.go
- query.go
- sample.go
- shift.go
- sideload.go
- state_tracking.go
- stats.go
- stream.go
- swarm_autoscale.go
- udf.go
- union.go
- where.go
- window.go