pipeline

May 17, 2018

Changes in this version

type AlertHTTPPostHandler

+ func (n AlertHTTPPostHandler) ChangeDetect(field string) *ChangeDetectNode

type AlertNode

+ func (n AlertNode) ChangeDetect(field string) *ChangeDetectNode

type AlertNodeData

+ Category string

+ Inhibitors []Inhibitor

+ KafkaHandlers []*KafkaHandler

+ OpsGenie2Handlers []*OpsGenie2Handler

+ PagerDuty2Handlers []*PagerDuty2Handler

+ func (n *AlertNodeData) ChangeDetect(field string) *ChangeDetectNode

+ func (n *AlertNodeData) Inhibit(category string, equalTags ...string) *AlertNodeData

+ func (n *AlertNodeData) Kafka() *KafkaHandler

+ func (n *AlertNodeData) OpsGenie2() *OpsGenie2Handler

+ func (n *AlertNodeData) PagerDuty2() *PagerDuty2Handler

type AlertaHandler

+ func (n AlertaHandler) ChangeDetect(field string) *ChangeDetectNode

type BarrierNode

+ func (n *BarrierNode) ChangeDetect(field string) *ChangeDetectNode

type BatchNode

+ func (n *BatchNode) IsQuiet() bool

+ func (n *BatchNode) Quiet()

+ type ChangeDetectNode struct

+ Field string

+ func (n *ChangeDetectNode) Alert() *AlertNode

+ func (n *ChangeDetectNode) Barrier() *BarrierNode

+ func (n *ChangeDetectNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *ChangeDetectNode) ChangeDetect(field string) *ChangeDetectNode

+ func (n *ChangeDetectNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *ChangeDetectNode) Count(field string) *InfluxQLNode

+ func (n *ChangeDetectNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *ChangeDetectNode) Default() *DefaultNode

+ func (n *ChangeDetectNode) Delete() *DeleteNode

+ func (n *ChangeDetectNode) Derivative(field string) *DerivativeNode

+ func (n *ChangeDetectNode) Difference(field string) *InfluxQLNode

+ func (n *ChangeDetectNode) Distinct(field string) *InfluxQLNode

+ func (n *ChangeDetectNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *ChangeDetectNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n *ChangeDetectNode) Eval(expressions ...*ast.LambdaNode) *EvalNode

+ func (n *ChangeDetectNode) First(field string) *InfluxQLNode

+ func (n *ChangeDetectNode) Flatten() *FlattenNode

+ func (n *ChangeDetectNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *ChangeDetectNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *ChangeDetectNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *ChangeDetectNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *ChangeDetectNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *ChangeDetectNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *ChangeDetectNode) Join(others ...Node) *JoinNode

+ func (n *ChangeDetectNode) K8sAutoscale() *K8sAutoscaleNode

+ func (n *ChangeDetectNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *ChangeDetectNode) Last(field string) *InfluxQLNode

+ func (n *ChangeDetectNode) Log() *LogNode

+ func (n *ChangeDetectNode) MarshalJSON() ([]byte, error)

+ func (n *ChangeDetectNode) Max(field string) *InfluxQLNode

+ func (n *ChangeDetectNode) Mean(field string) *InfluxQLNode

+ func (n *ChangeDetectNode) Median(field string) *InfluxQLNode

+ func (n *ChangeDetectNode) Min(field string) *InfluxQLNode

+ func (n *ChangeDetectNode) Mode(field string) *InfluxQLNode

+ func (n *ChangeDetectNode) MovingAverage(field string, window int64) *InfluxQLNode

+ func (n *ChangeDetectNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *ChangeDetectNode) Sample(rate interface{}) *SampleNode

+ func (n *ChangeDetectNode) Shift(shift time.Duration) *ShiftNode

+ func (n *ChangeDetectNode) Sideload() *SideloadNode

+ func (n *ChangeDetectNode) Spread(field string) *InfluxQLNode

+ func (n *ChangeDetectNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *ChangeDetectNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

+ func (n *ChangeDetectNode) Stddev(field string) *InfluxQLNode

+ func (n *ChangeDetectNode) Sum(field string) *InfluxQLNode

+ func (n *ChangeDetectNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *ChangeDetectNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *ChangeDetectNode) Union(node ...Node) *UnionNode

+ func (n *ChangeDetectNode) UnmarshalJSON(data []byte) error

+ func (n *ChangeDetectNode) Where(expression *ast.LambdaNode) *WhereNode

+ func (n *ChangeDetectNode) Window() *WindowNode

type CombineNode

+ func (n *CombineNode) ChangeDetect(field string) *ChangeDetectNode

type DefaultNode

+ func (n *DefaultNode) ChangeDetect(field string) *ChangeDetectNode

type DeleteNode

+ func (n *DeleteNode) ChangeDetect(field string) *ChangeDetectNode

type DerivativeNode

+ func (n *DerivativeNode) ChangeDetect(field string) *ChangeDetectNode

type Ec2AutoscaleNode

+ func (n *Ec2AutoscaleNode) ChangeDetect(field string) *ChangeDetectNode

type EmailHandler

+ func (n EmailHandler) ChangeDetect(field string) *ChangeDetectNode

type EvalNode

+ func (n *EvalNode) ChangeDetect(field string) *ChangeDetectNode

type ExecHandler

+ func (n ExecHandler) ChangeDetect(field string) *ChangeDetectNode

type FlattenNode

+ func (n *FlattenNode) ChangeDetect(field string) *ChangeDetectNode

type FromNode

+ func (n *FromNode) ChangeDetect(field string) *ChangeDetectNode

type GroupByNode

+ func (n *GroupByNode) ChangeDetect(field string) *ChangeDetectNode

type HTTPOutNode

+ func (n *HTTPOutNode) ChangeDetect(field string) *ChangeDetectNode

type HTTPPostNode

+ func (n *HTTPPostNode) ChangeDetect(field string) *ChangeDetectNode

type HipChatHandler

+ func (n HipChatHandler) ChangeDetect(field string) *ChangeDetectNode

type InfluxDBOutNode

+ func (n *InfluxDBOutNode) IsQuiet() bool

+ func (n *InfluxDBOutNode) Quiet()

type InfluxQLNode

+ func (n *InfluxQLNode) ChangeDetect(field string) *ChangeDetectNode

+ type Inhibitor struct

+ Category string

+ EqualTags []string

type JoinNode

+ func (n *JoinNode) ChangeDetect(field string) *ChangeDetectNode

type K8sAutoscaleNode

+ func (n *K8sAutoscaleNode) ChangeDetect(field string) *ChangeDetectNode

+ type KafkaHandler struct

+ Cluster string

+ KafkaTopic string

+ Template string

+ func (n KafkaHandler) Alert() *AlertNode

+ func (n KafkaHandler) Barrier() *BarrierNode

+ func (n KafkaHandler) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n KafkaHandler) ChangeDetect(field string) *ChangeDetectNode

+ func (n KafkaHandler) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n KafkaHandler) Count(field string) *InfluxQLNode

+ func (n KafkaHandler) CumulativeSum(field string) *InfluxQLNode

+ func (n KafkaHandler) Default() *DefaultNode

+ func (n KafkaHandler) Delete() *DeleteNode

+ func (n KafkaHandler) Derivative(field string) *DerivativeNode

+ func (n KafkaHandler) Difference(field string) *InfluxQLNode

+ func (n KafkaHandler) Distinct(field string) *InfluxQLNode

+ func (n KafkaHandler) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n KafkaHandler) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n KafkaHandler) Eval(expressions ...*ast.LambdaNode) *EvalNode

+ func (n KafkaHandler) First(field string) *InfluxQLNode

+ func (n KafkaHandler) Flatten() *FlattenNode

+ func (n KafkaHandler) GroupBy(tag ...interface{}) *GroupByNode

+ func (n KafkaHandler) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n KafkaHandler) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n KafkaHandler) HttpOut(endpoint string) *HTTPOutNode

+ func (n KafkaHandler) HttpPost(url ...string) *HTTPPostNode

+ func (n KafkaHandler) InfluxDBOut() *InfluxDBOutNode

+ func (n KafkaHandler) Join(others ...Node) *JoinNode

+ func (n KafkaHandler) K8sAutoscale() *K8sAutoscaleNode

+ func (n KafkaHandler) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n KafkaHandler) Last(field string) *InfluxQLNode

+ func (n KafkaHandler) Max(field string) *InfluxQLNode

+ func (n KafkaHandler) Mean(field string) *InfluxQLNode

+ func (n KafkaHandler) Median(field string) *InfluxQLNode

+ func (n KafkaHandler) Min(field string) *InfluxQLNode

+ func (n KafkaHandler) Mode(field string) *InfluxQLNode

+ func (n KafkaHandler) MovingAverage(field string, window int64) *InfluxQLNode

+ func (n KafkaHandler) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n KafkaHandler) Sample(rate interface{}) *SampleNode

+ func (n KafkaHandler) Shift(shift time.Duration) *ShiftNode

+ func (n KafkaHandler) Sideload() *SideloadNode

+ func (n KafkaHandler) Spread(field string) *InfluxQLNode

+ func (n KafkaHandler) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n KafkaHandler) StateDuration(expression *ast.LambdaNode) *StateDurationNode

+ func (n KafkaHandler) Stddev(field string) *InfluxQLNode

+ func (n KafkaHandler) Sum(field string) *InfluxQLNode

+ func (n KafkaHandler) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n KafkaHandler) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n KafkaHandler) Union(node ...Node) *UnionNode

+ func (n KafkaHandler) Where(expression *ast.LambdaNode) *WhereNode

+ func (n KafkaHandler) Window() *WindowNode

type KapacitorLoopbackNode

+ func (n *KapacitorLoopbackNode) IsQuiet() bool

+ func (n *KapacitorLoopbackNode) Quiet()

type LogHandler

+ func (n LogHandler) ChangeDetect(field string) *ChangeDetectNode

type LogNode

+ func (n *LogNode) ChangeDetect(field string) *ChangeDetectNode

type MQTTHandler

+ func (n MQTTHandler) ChangeDetect(field string) *ChangeDetectNode

type NoOpNode

+ func (n *NoOpNode) ChangeDetect(field string) *ChangeDetectNode

type Node

+ IsQuiet func() bool

+ type OpsGenie2Handler struct

+ RecipientsList []string

+ TeamsList []string

+ func (n OpsGenie2Handler) Alert() *AlertNode

+ func (n OpsGenie2Handler) Barrier() *BarrierNode

+ func (n OpsGenie2Handler) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n OpsGenie2Handler) ChangeDetect(field string) *ChangeDetectNode

+ func (n OpsGenie2Handler) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n OpsGenie2Handler) Count(field string) *InfluxQLNode

+ func (n OpsGenie2Handler) CumulativeSum(field string) *InfluxQLNode

+ func (n OpsGenie2Handler) Default() *DefaultNode

+ func (n OpsGenie2Handler) Delete() *DeleteNode

+ func (n OpsGenie2Handler) Derivative(field string) *DerivativeNode

+ func (n OpsGenie2Handler) Difference(field string) *InfluxQLNode

+ func (n OpsGenie2Handler) Distinct(field string) *InfluxQLNode

+ func (n OpsGenie2Handler) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n OpsGenie2Handler) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n OpsGenie2Handler) Eval(expressions ...*ast.LambdaNode) *EvalNode

+ func (n OpsGenie2Handler) First(field string) *InfluxQLNode

+ func (n OpsGenie2Handler) Flatten() *FlattenNode

+ func (n OpsGenie2Handler) GroupBy(tag ...interface{}) *GroupByNode

+ func (n OpsGenie2Handler) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n OpsGenie2Handler) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n OpsGenie2Handler) HttpOut(endpoint string) *HTTPOutNode

+ func (n OpsGenie2Handler) HttpPost(url ...string) *HTTPPostNode

+ func (n OpsGenie2Handler) InfluxDBOut() *InfluxDBOutNode

+ func (n OpsGenie2Handler) Join(others ...Node) *JoinNode

+ func (n OpsGenie2Handler) K8sAutoscale() *K8sAutoscaleNode

+ func (n OpsGenie2Handler) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n OpsGenie2Handler) Last(field string) *InfluxQLNode

+ func (n OpsGenie2Handler) Max(field string) *InfluxQLNode

+ func (n OpsGenie2Handler) Mean(field string) *InfluxQLNode

+ func (n OpsGenie2Handler) Median(field string) *InfluxQLNode

+ func (n OpsGenie2Handler) Min(field string) *InfluxQLNode

+ func (n OpsGenie2Handler) Mode(field string) *InfluxQLNode

+ func (n OpsGenie2Handler) MovingAverage(field string, window int64) *InfluxQLNode

+ func (n OpsGenie2Handler) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n OpsGenie2Handler) Sample(rate interface{}) *SampleNode

+ func (n OpsGenie2Handler) Shift(shift time.Duration) *ShiftNode

+ func (n OpsGenie2Handler) Sideload() *SideloadNode

+ func (n OpsGenie2Handler) Spread(field string) *InfluxQLNode

+ func (n OpsGenie2Handler) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n OpsGenie2Handler) StateDuration(expression *ast.LambdaNode) *StateDurationNode

+ func (n OpsGenie2Handler) Stddev(field string) *InfluxQLNode

+ func (n OpsGenie2Handler) Sum(field string) *InfluxQLNode

+ func (n OpsGenie2Handler) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n OpsGenie2Handler) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n OpsGenie2Handler) Union(node ...Node) *UnionNode

+ func (n OpsGenie2Handler) Where(expression *ast.LambdaNode) *WhereNode

+ func (n OpsGenie2Handler) Window() *WindowNode

+ func (og *OpsGenie2Handler) Recipients(recipients ...string) *OpsGenie2Handler

+ func (og *OpsGenie2Handler) Teams(teams ...string) *OpsGenie2Handler

type OpsGenieHandler

+ func (n OpsGenieHandler) ChangeDetect(field string) *ChangeDetectNode

+ type PagerDuty2Handler struct

+ ServiceKey string

+ func (n PagerDuty2Handler) Alert() *AlertNode

+ func (n PagerDuty2Handler) Barrier() *BarrierNode

+ func (n PagerDuty2Handler) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n PagerDuty2Handler) ChangeDetect(field string) *ChangeDetectNode

+ func (n PagerDuty2Handler) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n PagerDuty2Handler) Count(field string) *InfluxQLNode

+ func (n PagerDuty2Handler) CumulativeSum(field string) *InfluxQLNode

+ func (n PagerDuty2Handler) Default() *DefaultNode

+ func (n PagerDuty2Handler) Delete() *DeleteNode

+ func (n PagerDuty2Handler) Derivative(field string) *DerivativeNode

+ func (n PagerDuty2Handler) Difference(field string) *InfluxQLNode

+ func (n PagerDuty2Handler) Distinct(field string) *InfluxQLNode

+ func (n PagerDuty2Handler) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n PagerDuty2Handler) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n PagerDuty2Handler) Eval(expressions ...*ast.LambdaNode) *EvalNode

+ func (n PagerDuty2Handler) First(field string) *InfluxQLNode

+ func (n PagerDuty2Handler) Flatten() *FlattenNode

+ func (n PagerDuty2Handler) GroupBy(tag ...interface{}) *GroupByNode

+ func (n PagerDuty2Handler) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n PagerDuty2Handler) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n PagerDuty2Handler) HttpOut(endpoint string) *HTTPOutNode

+ func (n PagerDuty2Handler) HttpPost(url ...string) *HTTPPostNode

+ func (n PagerDuty2Handler) InfluxDBOut() *InfluxDBOutNode

+ func (n PagerDuty2Handler) Join(others ...Node) *JoinNode

+ func (n PagerDuty2Handler) K8sAutoscale() *K8sAutoscaleNode

+ func (n PagerDuty2Handler) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n PagerDuty2Handler) Last(field string) *InfluxQLNode

+ func (n PagerDuty2Handler) Max(field string) *InfluxQLNode

+ func (n PagerDuty2Handler) Mean(field string) *InfluxQLNode

+ func (n PagerDuty2Handler) Median(field string) *InfluxQLNode

+ func (n PagerDuty2Handler) Min(field string) *InfluxQLNode

+ func (n PagerDuty2Handler) Mode(field string) *InfluxQLNode

+ func (n PagerDuty2Handler) MovingAverage(field string, window int64) *InfluxQLNode

+ func (n PagerDuty2Handler) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n PagerDuty2Handler) Sample(rate interface{}) *SampleNode

+ func (n PagerDuty2Handler) Shift(shift time.Duration) *ShiftNode

+ func (n PagerDuty2Handler) Sideload() *SideloadNode

+ func (n PagerDuty2Handler) Spread(field string) *InfluxQLNode

+ func (n PagerDuty2Handler) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n PagerDuty2Handler) StateDuration(expression *ast.LambdaNode) *StateDurationNode

+ func (n PagerDuty2Handler) Stddev(field string) *InfluxQLNode

+ func (n PagerDuty2Handler) Sum(field string) *InfluxQLNode

+ func (n PagerDuty2Handler) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n PagerDuty2Handler) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n PagerDuty2Handler) Union(node ...Node) *UnionNode

+ func (n PagerDuty2Handler) Where(expression *ast.LambdaNode) *WhereNode

+ func (n PagerDuty2Handler) Window() *WindowNode

type PagerDutyHandler

+ func (n PagerDutyHandler) ChangeDetect(field string) *ChangeDetectNode

type PushoverHandler

+ func (n PushoverHandler) ChangeDetect(field string) *ChangeDetectNode

type QueryNode

+ func (n *QueryNode) ChangeDetect(field string) *ChangeDetectNode

type SNMPTrapHandler

+ func (n SNMPTrapHandler) ChangeDetect(field string) *ChangeDetectNode

type SampleNode

+ func (n *SampleNode) ChangeDetect(field string) *ChangeDetectNode

type SensuHandler

+ func (n SensuHandler) ChangeDetect(field string) *ChangeDetectNode

type ShiftNode

+ func (n *ShiftNode) ChangeDetect(field string) *ChangeDetectNode

type SideloadNode

+ func (n *SideloadNode) ChangeDetect(field string) *ChangeDetectNode

type SlackHandler

+ Workspace string

+ func (n SlackHandler) ChangeDetect(field string) *ChangeDetectNode

type StateCountNode

+ func (n *StateCountNode) ChangeDetect(field string) *ChangeDetectNode

type StateDurationNode

+ func (n *StateDurationNode) ChangeDetect(field string) *ChangeDetectNode

type StatsNode

+ func (n *StatsNode) ChangeDetect(field string) *ChangeDetectNode

type StreamNode

+ func (n *StreamNode) IsQuiet() bool

+ func (n *StreamNode) Quiet()

type SwarmAutoscaleNode

+ func (n *SwarmAutoscaleNode) ChangeDetect(field string) *ChangeDetectNode

type TalkHandler

+ func (n TalkHandler) ChangeDetect(field string) *ChangeDetectNode

type TcpHandler

+ func (n TcpHandler) ChangeDetect(field string) *ChangeDetectNode

type TelegramHandler

+ func (n TelegramHandler) ChangeDetect(field string) *ChangeDetectNode

type UDFNode

+ func (n *UDFNode) ChangeDetect(field string) *ChangeDetectNode

type UnionNode

+ func (n *UnionNode) ChangeDetect(field string) *ChangeDetectNode

type VictorOpsHandler

+ func (n VictorOpsHandler) ChangeDetect(field string) *ChangeDetectNode

type WhereNode

+ func (n *WhereNode) ChangeDetect(field string) *ChangeDetectNode

type WindowNode

+ func (n *WindowNode) ChangeDetect(field string) *ChangeDetectNode

Dec 8, 2017

Changes in this version

+ const NodeID

+ const NodeTypeOf

+ func Validate(p *Pipeline) error

type AlertHTTPPostHandler

+ CaptureResponseFlag bool

+ Timeout time.Duration

+ func (a *AlertHTTPPostHandler) CaptureResponse() *AlertHTTPPostHandler

+ func (n AlertHTTPPostHandler) Barrier() *BarrierNode

+ func (n AlertHTTPPostHandler) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n AlertHTTPPostHandler) Sideload() *SideloadNode

+ func (n AlertHTTPPostHandler) SwarmAutoscale() *SwarmAutoscaleNode

type AlertNode

+ func (n *AlertNode) MarshalJSON() ([]byte, error)

+ func (n *AlertNode) UnmarshalJSON(data []byte) error

+ func (n AlertNode) Barrier() *BarrierNode

+ func (n AlertNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n AlertNode) Sideload() *SideloadNode

+ func (n AlertNode) SwarmAutoscale() *SwarmAutoscaleNode

+ type AlertNodeData struct

+ AlertaHandlers []*AlertaHandler

+ AllFlag bool

+ Crit *ast.LambdaNode

+ CritReset *ast.LambdaNode

+ Details string

+ DurationField string

+ EmailHandlers []*EmailHandler

+ ExecHandlers []*ExecHandler

+ FlapHigh float64

+ FlapLow float64

+ HTTPPostHandlers []*AlertHTTPPostHandler

+ HipChatHandlers []*HipChatHandler

+ History int64

+ Id string

+ IdField string

+ IdTag string

+ Info *ast.LambdaNode

+ InfoReset *ast.LambdaNode

+ IsStateChangesOnly bool

+ LevelField string

+ LevelTag string

+ LogHandlers []*LogHandler

+ MQTTHandlers []*MQTTHandler

+ Message string

+ MessageField string

+ NoRecoveriesFlag bool

+ OpsGenieHandlers []*OpsGenieHandler

+ PagerDutyHandlers []*PagerDutyHandler

+ PushoverHandlers []*PushoverHandler

+ SNMPTrapHandlers []*SNMPTrapHandler

+ SensuHandlers []*SensuHandler

+ SlackHandlers []*SlackHandler

+ StateChangesOnlyDuration time.Duration

+ TalkHandlers []*TalkHandler

+ TcpHandlers []*TcpHandler

+ TelegramHandlers []*TelegramHandler

+ Topic string

+ UseFlapping bool

+ VictorOpsHandlers []*VictorOpsHandler

+ Warn *ast.LambdaNode

+ WarnReset *ast.LambdaNode

+ func (n *AlertNodeData) Alert() *AlertNode

+ func (n *AlertNodeData) Alerta() *AlertaHandler

+ func (n *AlertNodeData) All() *AlertNodeData

+ func (n *AlertNodeData) Barrier() *BarrierNode

+ func (n *AlertNodeData) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *AlertNodeData) ChainMethods() map[string]reflect.Value

+ func (n *AlertNodeData) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *AlertNodeData) Count(field string) *InfluxQLNode

+ func (n *AlertNodeData) CumulativeSum(field string) *InfluxQLNode

+ func (n *AlertNodeData) Default() *DefaultNode

+ func (n *AlertNodeData) Delete() *DeleteNode

+ func (n *AlertNodeData) Derivative(field string) *DerivativeNode

+ func (n *AlertNodeData) Difference(field string) *InfluxQLNode

+ func (n *AlertNodeData) Distinct(field string) *InfluxQLNode

+ func (n *AlertNodeData) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *AlertNodeData) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n *AlertNodeData) Email(to ...string) *EmailHandler

+ func (n *AlertNodeData) Eval(expressions ...*ast.LambdaNode) *EvalNode

+ func (n *AlertNodeData) Exec(executable string, args ...string) *ExecHandler

+ func (n *AlertNodeData) First(field string) *InfluxQLNode

+ func (n *AlertNodeData) Flapping(low, high float64) *AlertNodeData

+ func (n *AlertNodeData) Flatten() *FlattenNode

+ func (n *AlertNodeData) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *AlertNodeData) HipChat() *HipChatHandler

+ func (n *AlertNodeData) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *AlertNodeData) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *AlertNodeData) HttpOut(endpoint string) *HTTPOutNode

+ func (n *AlertNodeData) HttpPost(url ...string) *HTTPPostNode

+ func (n *AlertNodeData) InfluxDBOut() *InfluxDBOutNode

+ func (n *AlertNodeData) Join(others ...Node) *JoinNode

+ func (n *AlertNodeData) K8sAutoscale() *K8sAutoscaleNode

+ func (n *AlertNodeData) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *AlertNodeData) Last(field string) *InfluxQLNode

+ func (n *AlertNodeData) Log(filepath string) *LogHandler

+ func (n *AlertNodeData) Max(field string) *InfluxQLNode

+ func (n *AlertNodeData) Mean(field string) *InfluxQLNode

+ func (n *AlertNodeData) Median(field string) *InfluxQLNode

+ func (n *AlertNodeData) Min(field string) *InfluxQLNode

+ func (n *AlertNodeData) Mode(field string) *InfluxQLNode

+ func (n *AlertNodeData) MovingAverage(field string, window int64) *InfluxQLNode

+ func (n *AlertNodeData) Mqtt(topic string) *MQTTHandler

+ func (n *AlertNodeData) NoRecoveries() *AlertNodeData

+ func (n *AlertNodeData) OpsGenie() *OpsGenieHandler

+ func (n *AlertNodeData) PagerDuty() *PagerDutyHandler

+ func (n *AlertNodeData) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *AlertNodeData) Post(urls ...string) *AlertHTTPPostHandler

+ func (n *AlertNodeData) Pushover() *PushoverHandler

+ func (n *AlertNodeData) Sample(rate interface{}) *SampleNode

+ func (n *AlertNodeData) Sensu() *SensuHandler

+ func (n *AlertNodeData) Shift(shift time.Duration) *ShiftNode

+ func (n *AlertNodeData) Sideload() *SideloadNode

+ func (n *AlertNodeData) Slack() *SlackHandler

+ func (n *AlertNodeData) SnmpTrap(trapOid string) *SNMPTrapHandler

+ func (n *AlertNodeData) Spread(field string) *InfluxQLNode

+ func (n *AlertNodeData) StateChangesOnly(maxInterval ...time.Duration) *AlertNodeData

+ func (n *AlertNodeData) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *AlertNodeData) StateDuration(expression *ast.LambdaNode) *StateDurationNode

+ func (n *AlertNodeData) Stddev(field string) *InfluxQLNode

+ func (n *AlertNodeData) Sum(field string) *InfluxQLNode

+ func (n *AlertNodeData) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *AlertNodeData) Talk() *TalkHandler

+ func (n *AlertNodeData) Tcp(address string) *TcpHandler

+ func (n *AlertNodeData) Telegram() *TelegramHandler

+ func (n *AlertNodeData) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *AlertNodeData) Union(node ...Node) *UnionNode

+ func (n *AlertNodeData) VictorOps() *VictorOpsHandler

+ func (n *AlertNodeData) Where(expression *ast.LambdaNode) *WhereNode

+ func (n *AlertNodeData) Window() *WindowNode

type AlertaHandler

+ Timeout time.Duration

+ func (n AlertaHandler) Barrier() *BarrierNode

+ func (n AlertaHandler) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n AlertaHandler) Sideload() *SideloadNode

+ func (n AlertaHandler) SwarmAutoscale() *SwarmAutoscaleNode

+ type BarrierNode struct

+ Idle time.Duration

+ Period time.Duration

+ func (n *BarrierNode) Alert() *AlertNode

+ func (n *BarrierNode) Barrier() *BarrierNode

+ func (n *BarrierNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *BarrierNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *BarrierNode) Count(field string) *InfluxQLNode

+ func (n *BarrierNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *BarrierNode) Default() *DefaultNode

+ func (n *BarrierNode) Delete() *DeleteNode

+ func (n *BarrierNode) Derivative(field string) *DerivativeNode

+ func (n *BarrierNode) Difference(field string) *InfluxQLNode

+ func (n *BarrierNode) Distinct(field string) *InfluxQLNode

+ func (n *BarrierNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *BarrierNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n *BarrierNode) Eval(expressions ...*ast.LambdaNode) *EvalNode

+ func (n *BarrierNode) First(field string) *InfluxQLNode

+ func (n *BarrierNode) Flatten() *FlattenNode

+ func (n *BarrierNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *BarrierNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *BarrierNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *BarrierNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *BarrierNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *BarrierNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *BarrierNode) Join(others ...Node) *JoinNode

+ func (n *BarrierNode) K8sAutoscale() *K8sAutoscaleNode

+ func (n *BarrierNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *BarrierNode) Last(field string) *InfluxQLNode

+ func (n *BarrierNode) Log() *LogNode

+ func (n *BarrierNode) MarshalJSON() ([]byte, error)

+ func (n *BarrierNode) Max(field string) *InfluxQLNode

+ func (n *BarrierNode) Mean(field string) *InfluxQLNode

+ func (n *BarrierNode) Median(field string) *InfluxQLNode

+ func (n *BarrierNode) Min(field string) *InfluxQLNode

+ func (n *BarrierNode) Mode(field string) *InfluxQLNode

+ func (n *BarrierNode) MovingAverage(field string, window int64) *InfluxQLNode

+ func (n *BarrierNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *BarrierNode) Sample(rate interface{}) *SampleNode

+ func (n *BarrierNode) Shift(shift time.Duration) *ShiftNode

+ func (n *BarrierNode) Sideload() *SideloadNode

+ func (n *BarrierNode) Spread(field string) *InfluxQLNode

+ func (n *BarrierNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *BarrierNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

+ func (n *BarrierNode) Stddev(field string) *InfluxQLNode

+ func (n *BarrierNode) Sum(field string) *InfluxQLNode

+ func (n *BarrierNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *BarrierNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *BarrierNode) Union(node ...Node) *UnionNode

+ func (n *BarrierNode) UnmarshalJSON(data []byte) error

+ func (n *BarrierNode) Where(expression *ast.LambdaNode) *WhereNode

+ func (n *BarrierNode) Window() *WindowNode

type BatchNode

+ func (n *BatchNode) MarshalJSON() ([]byte, error)

+ func (n *BatchNode) UnmarshalJSON(data []byte) error

type CombineNode

+ func (n *CombineNode) Barrier() *BarrierNode

+ func (n *CombineNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *CombineNode) MarshalJSON() ([]byte, error)

+ func (n *CombineNode) Sideload() *SideloadNode

+ func (n *CombineNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *CombineNode) UnmarshalJSON(data []byte) error

type DefaultNode

+ func (n *DefaultNode) Barrier() *BarrierNode

+ func (n *DefaultNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *DefaultNode) MarshalJSON() ([]byte, error)

+ func (n *DefaultNode) Sideload() *SideloadNode

+ func (n *DefaultNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *DefaultNode) UnmarshalJSON(data []byte) error

type DeleteNode

+ func (n *DeleteNode) Barrier() *BarrierNode

+ func (n *DeleteNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *DeleteNode) MarshalJSON() ([]byte, error)

+ func (n *DeleteNode) Sideload() *SideloadNode

+ func (n *DeleteNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *DeleteNode) UnmarshalJSON(data []byte) error

type DerivativeNode

+ func (n *DerivativeNode) Barrier() *BarrierNode

+ func (n *DerivativeNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *DerivativeNode) MarshalJSON() ([]byte, error)

+ func (n *DerivativeNode) Sideload() *SideloadNode

+ func (n *DerivativeNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *DerivativeNode) UnmarshalJSON(data []byte) error

+ type Ec2AutoscaleNode struct

+ Cluster string

+ CurrentField string

+ DecreaseCooldown time.Duration

+ GroupName string

+ GroupNameTag string

+ IncreaseCooldown time.Duration

+ Max int64

+ Min int64

+ OutputGroupNameTag string

+ Replicas *ast.LambdaNode

+ func (n *Ec2AutoscaleNode) Alert() *AlertNode

+ func (n *Ec2AutoscaleNode) Barrier() *BarrierNode

+ func (n *Ec2AutoscaleNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *Ec2AutoscaleNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *Ec2AutoscaleNode) Count(field string) *InfluxQLNode

+ func (n *Ec2AutoscaleNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *Ec2AutoscaleNode) Default() *DefaultNode

+ func (n *Ec2AutoscaleNode) Delete() *DeleteNode

+ func (n *Ec2AutoscaleNode) Derivative(field string) *DerivativeNode

+ func (n *Ec2AutoscaleNode) Difference(field string) *InfluxQLNode

+ func (n *Ec2AutoscaleNode) Distinct(field string) *InfluxQLNode

+ func (n *Ec2AutoscaleNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *Ec2AutoscaleNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n *Ec2AutoscaleNode) Eval(expressions ...*ast.LambdaNode) *EvalNode

+ func (n *Ec2AutoscaleNode) First(field string) *InfluxQLNode

+ func (n *Ec2AutoscaleNode) Flatten() *FlattenNode

+ func (n *Ec2AutoscaleNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *Ec2AutoscaleNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *Ec2AutoscaleNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *Ec2AutoscaleNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *Ec2AutoscaleNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *Ec2AutoscaleNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *Ec2AutoscaleNode) Join(others ...Node) *JoinNode

+ func (n *Ec2AutoscaleNode) K8sAutoscale() *K8sAutoscaleNode

+ func (n *Ec2AutoscaleNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *Ec2AutoscaleNode) Last(field string) *InfluxQLNode

+ func (n *Ec2AutoscaleNode) Log() *LogNode

+ func (n *Ec2AutoscaleNode) Mean(field string) *InfluxQLNode

+ func (n *Ec2AutoscaleNode) Median(field string) *InfluxQLNode

+ func (n *Ec2AutoscaleNode) Mode(field string) *InfluxQLNode

+ func (n *Ec2AutoscaleNode) MovingAverage(field string, window int64) *InfluxQLNode

+ func (n *Ec2AutoscaleNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *Ec2AutoscaleNode) Sample(rate interface{}) *SampleNode

+ func (n *Ec2AutoscaleNode) Shift(shift time.Duration) *ShiftNode

+ func (n *Ec2AutoscaleNode) Sideload() *SideloadNode

+ func (n *Ec2AutoscaleNode) Spread(field string) *InfluxQLNode

+ func (n *Ec2AutoscaleNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *Ec2AutoscaleNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

+ func (n *Ec2AutoscaleNode) Stddev(field string) *InfluxQLNode

+ func (n *Ec2AutoscaleNode) Sum(field string) *InfluxQLNode

+ func (n *Ec2AutoscaleNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *Ec2AutoscaleNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *Ec2AutoscaleNode) Union(node ...Node) *UnionNode

+ func (n *Ec2AutoscaleNode) Where(expression *ast.LambdaNode) *WhereNode

+ func (n *Ec2AutoscaleNode) Window() *WindowNode

+ type Edge struct

+ Child ID

+ Parent ID

type EmailHandler

+ func (n EmailHandler) Barrier() *BarrierNode

+ func (n EmailHandler) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n EmailHandler) Sideload() *SideloadNode

+ func (n EmailHandler) SwarmAutoscale() *SwarmAutoscaleNode

type EvalNode

+ func (n *EvalNode) Barrier() *BarrierNode

+ func (n *EvalNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *EvalNode) MarshalJSON() ([]byte, error)

+ func (n *EvalNode) Sideload() *SideloadNode

+ func (n *EvalNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *EvalNode) UnmarshalJSON(data []byte) error

type ExecHandler

+ func (n ExecHandler) Barrier() *BarrierNode

+ func (n ExecHandler) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n ExecHandler) Sideload() *SideloadNode

+ func (n ExecHandler) SwarmAutoscale() *SwarmAutoscaleNode

type FlattenNode

+ func (n *FlattenNode) Barrier() *BarrierNode

+ func (n *FlattenNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *FlattenNode) MarshalJSON() ([]byte, error)

+ func (n *FlattenNode) Sideload() *SideloadNode

+ func (n *FlattenNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *FlattenNode) UnmarshalJSON(data []byte) error

type FromNode

+ func (n *FromNode) Barrier() *BarrierNode

+ func (n *FromNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *FromNode) MarshalJSON() ([]byte, error)

+ func (n *FromNode) Sideload() *SideloadNode

+ func (n *FromNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *FromNode) UnmarshalJSON(data []byte) error

+ type Graph map[ID][]ID

type GroupByNode

+ func (n *GroupByNode) Barrier() *BarrierNode

+ func (n *GroupByNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *GroupByNode) MarshalJSON() ([]byte, error)

+ func (n *GroupByNode) Sideload() *SideloadNode

+ func (n *GroupByNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *GroupByNode) UnmarshalJSON(data []byte) error

type HTTPOutNode

+ func (n *HTTPOutNode) Barrier() *BarrierNode

+ func (n *HTTPOutNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *HTTPOutNode) MarshalJSON() ([]byte, error)

+ func (n *HTTPOutNode) Sideload() *SideloadNode

+ func (n *HTTPOutNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *HTTPOutNode) UnmarshalJSON(data []byte) error

type HTTPPostNode

+ CaptureResponseFlag bool

+ CodeField string

+ Timeout time.Duration

+ func (n *HTTPPostNode) Barrier() *BarrierNode

+ func (n *HTTPPostNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *HTTPPostNode) MarshalJSON() ([]byte, error)

+ func (n *HTTPPostNode) Sideload() *SideloadNode

+ func (n *HTTPPostNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *HTTPPostNode) UnmarshalJSON(data []byte) error

+ func (p *HTTPPostNode) CaptureResponse() *HTTPPostNode

type HipChatHandler

+ func (n HipChatHandler) Barrier() *BarrierNode

+ func (n HipChatHandler) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n HipChatHandler) Sideload() *SideloadNode

+ func (n HipChatHandler) SwarmAutoscale() *SwarmAutoscaleNode

+ type IRNode struct

+ Pos int

+ Raw json.RawMessage

+ TypeOf TypeOf

type InfluxDBOutNode

+ func (n *InfluxDBOutNode) MarshalJSON() ([]byte, error)

+ func (n *InfluxDBOutNode) UnmarshalJSON(data []byte) error

type InfluxQLNode

+ Args []interface{}

+ func (n *InfluxQLNode) Barrier() *BarrierNode

+ func (n *InfluxQLNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *InfluxQLNode) MarshalJSON() ([]byte, error)

+ func (n *InfluxQLNode) Sideload() *SideloadNode

+ func (n *InfluxQLNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *InfluxQLNode) UnmarshalJSON(data []byte) error

+ type JSONNode map[string]interface

+ func (j JSONNode) CheckTypeOf(typ string) error

+ func (j JSONNode) Field(field string) (interface{}, error)

+ func (j JSONNode) ID() (ID, error)

+ func (j JSONNode) Set(key string, value interface{}) JSONNode

+ func (j JSONNode) SetID(id ID) JSONNode

+ func (j JSONNode) SetType(typ string) JSONNode

+ func (j JSONNode) String(field string) (string, error)

+ func NewJSONNode(data []byte) (JSONNode, error)

+ type JSONPipeline struct

+ Edges []Edge

+ Nodes []json.RawMessage

type JoinNode

+ func (n *JoinNode) Barrier() *BarrierNode

+ func (n *JoinNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *JoinNode) MarshalJSON() ([]byte, error)

+ func (n *JoinNode) Sideload() *SideloadNode

+ func (n *JoinNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *JoinNode) UnmarshalJSON(data []byte) error

type K8sAutoscaleNode

+ func (n *K8sAutoscaleNode) Barrier() *BarrierNode

+ func (n *K8sAutoscaleNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *K8sAutoscaleNode) MarshalJSON() ([]byte, error)

+ func (n *K8sAutoscaleNode) Sideload() *SideloadNode

+ func (n *K8sAutoscaleNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *K8sAutoscaleNode) UnmarshalJSON(data []byte) error

type KapacitorLoopbackNode

+ func (n *KapacitorLoopbackNode) MarshalJSON() ([]byte, error)

+ func (n *KapacitorLoopbackNode) UnmarshalJSON(data []byte) error

type LogHandler

+ func (n LogHandler) Barrier() *BarrierNode

+ func (n LogHandler) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n LogHandler) Sideload() *SideloadNode

+ func (n LogHandler) SwarmAutoscale() *SwarmAutoscaleNode

type LogNode

+ func (n *LogNode) Barrier() *BarrierNode

+ func (n *LogNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *LogNode) MarshalJSON() ([]byte, error)

+ func (n *LogNode) Sideload() *SideloadNode

+ func (n *LogNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *LogNode) UnmarshalJSON(data []byte) error

+ type MQTTHandler struct

+ BrokerName string

+ Qos int64

+ Retained bool

+ Topic string

+ func (n MQTTHandler) Alert() *AlertNode

+ func (n MQTTHandler) Barrier() *BarrierNode

+ func (n MQTTHandler) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n MQTTHandler) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n MQTTHandler) Count(field string) *InfluxQLNode

+ func (n MQTTHandler) CumulativeSum(field string) *InfluxQLNode

+ func (n MQTTHandler) Default() *DefaultNode

+ func (n MQTTHandler) Delete() *DeleteNode

+ func (n MQTTHandler) Derivative(field string) *DerivativeNode

+ func (n MQTTHandler) Difference(field string) *InfluxQLNode

+ func (n MQTTHandler) Distinct(field string) *InfluxQLNode

+ func (n MQTTHandler) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n MQTTHandler) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n MQTTHandler) Eval(expressions ...*ast.LambdaNode) *EvalNode

+ func (n MQTTHandler) First(field string) *InfluxQLNode

+ func (n MQTTHandler) Flatten() *FlattenNode

+ func (n MQTTHandler) GroupBy(tag ...interface{}) *GroupByNode

+ func (n MQTTHandler) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n MQTTHandler) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n MQTTHandler) HttpOut(endpoint string) *HTTPOutNode

+ func (n MQTTHandler) HttpPost(url ...string) *HTTPPostNode

+ func (n MQTTHandler) InfluxDBOut() *InfluxDBOutNode

+ func (n MQTTHandler) Join(others ...Node) *JoinNode

+ func (n MQTTHandler) K8sAutoscale() *K8sAutoscaleNode

+ func (n MQTTHandler) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n MQTTHandler) Last(field string) *InfluxQLNode

+ func (n MQTTHandler) Max(field string) *InfluxQLNode

+ func (n MQTTHandler) Mean(field string) *InfluxQLNode

+ func (n MQTTHandler) Median(field string) *InfluxQLNode

+ func (n MQTTHandler) Min(field string) *InfluxQLNode

+ func (n MQTTHandler) Mode(field string) *InfluxQLNode

+ func (n MQTTHandler) MovingAverage(field string, window int64) *InfluxQLNode

+ func (n MQTTHandler) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n MQTTHandler) Sample(rate interface{}) *SampleNode

+ func (n MQTTHandler) Shift(shift time.Duration) *ShiftNode

+ func (n MQTTHandler) Sideload() *SideloadNode

+ func (n MQTTHandler) Spread(field string) *InfluxQLNode

+ func (n MQTTHandler) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n MQTTHandler) StateDuration(expression *ast.LambdaNode) *StateDurationNode

+ func (n MQTTHandler) Stddev(field string) *InfluxQLNode

+ func (n MQTTHandler) Sum(field string) *InfluxQLNode

+ func (n MQTTHandler) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n MQTTHandler) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n MQTTHandler) Union(node ...Node) *UnionNode

+ func (n MQTTHandler) Where(expression *ast.LambdaNode) *WhereNode

+ func (n MQTTHandler) Window() *WindowNode

type NoOpNode

+ func (n *NoOpNode) Barrier() *BarrierNode

+ func (n *NoOpNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *NoOpNode) MarshalJSON() ([]byte, error)

+ func (n *NoOpNode) Sideload() *SideloadNode

+ func (n *NoOpNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *NoOpNode) UnmarshalJSON(data []byte) error

type OpsGenieHandler

+ func (n OpsGenieHandler) Barrier() *BarrierNode

+ func (n OpsGenieHandler) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n OpsGenieHandler) Sideload() *SideloadNode

+ func (n OpsGenieHandler) SwarmAutoscale() *SwarmAutoscaleNode

type PagerDutyHandler

+ func (n PagerDutyHandler) Barrier() *BarrierNode

+ func (n PagerDutyHandler) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n PagerDutyHandler) Sideload() *SideloadNode

+ func (n PagerDutyHandler) SwarmAutoscale() *SwarmAutoscaleNode

type Pipeline

+ func CreatePipelineSources(srcs ...Node) *Pipeline

+ func (p *Pipeline) MarshalJSON() ([]byte, error)

+ func (p *Pipeline) Stats() []*StatsNode

+ func (p *Pipeline) Unmarshal(data []byte) error

+ type PipelineSorter struct

+ ChildrenOf Graph

+ Edges []Edge

+ ParentsOf Graph

+ SortedIndexes map[ID]int

+ func NewPipelineSorter(edges []Edge) *PipelineSorter

+ func (p *PipelineSorter) Graphs() (childrenOf Graph, parentsOf Graph)

+ func (p *PipelineSorter) Sort() (map[ID]int, error)

type PushoverHandler

+ func (n PushoverHandler) Barrier() *BarrierNode

+ func (n PushoverHandler) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n PushoverHandler) Sideload() *SideloadNode

+ func (n PushoverHandler) SwarmAutoscale() *SwarmAutoscaleNode

type QueryNode

+ func (n *QueryNode) Barrier() *BarrierNode

+ func (n *QueryNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *QueryNode) MarshalJSON() ([]byte, error)

+ func (n *QueryNode) Sideload() *SideloadNode

+ func (n *QueryNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *QueryNode) UnmarshalJSON(data []byte) error

type SNMPTrapHandler

+ func (n SNMPTrapHandler) Barrier() *BarrierNode

+ func (n SNMPTrapHandler) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n SNMPTrapHandler) Sideload() *SideloadNode

+ func (n SNMPTrapHandler) SwarmAutoscale() *SwarmAutoscaleNode

type SampleNode

+ func (n *SampleNode) Barrier() *BarrierNode

+ func (n *SampleNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *SampleNode) MarshalJSON() ([]byte, error)

+ func (n *SampleNode) Sideload() *SideloadNode

+ func (n *SampleNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *SampleNode) UnmarshalJSON(data []byte) error

type SensuHandler

+ func (n SensuHandler) Barrier() *BarrierNode

+ func (n SensuHandler) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n SensuHandler) Sideload() *SideloadNode

+ func (n SensuHandler) SwarmAutoscale() *SwarmAutoscaleNode

type ShiftNode

+ func (n *ShiftNode) Barrier() *BarrierNode

+ func (n *ShiftNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *ShiftNode) MarshalJSON() ([]byte, error)

+ func (n *ShiftNode) Sideload() *SideloadNode

+ func (n *ShiftNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *ShiftNode) UnmarshalJSON(data []byte) error

+ type SideloadNode struct

+ Fields map[string]interface{}

+ OrderList []string

+ Source string

+ Tags map[string]string

+ func (n *SideloadNode) Alert() *AlertNode

+ func (n *SideloadNode) Barrier() *BarrierNode

+ func (n *SideloadNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *SideloadNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *SideloadNode) Count(field string) *InfluxQLNode

+ func (n *SideloadNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *SideloadNode) Default() *DefaultNode

+ func (n *SideloadNode) Delete() *DeleteNode

+ func (n *SideloadNode) Derivative(field string) *DerivativeNode

+ func (n *SideloadNode) Difference(field string) *InfluxQLNode

+ func (n *SideloadNode) Distinct(field string) *InfluxQLNode

+ func (n *SideloadNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *SideloadNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n *SideloadNode) Eval(expressions ...*ast.LambdaNode) *EvalNode

+ func (n *SideloadNode) Field(f string, v interface{}) *SideloadNode

+ func (n *SideloadNode) First(field string) *InfluxQLNode

+ func (n *SideloadNode) Flatten() *FlattenNode

+ func (n *SideloadNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *SideloadNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *SideloadNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *SideloadNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *SideloadNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *SideloadNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *SideloadNode) Join(others ...Node) *JoinNode

+ func (n *SideloadNode) K8sAutoscale() *K8sAutoscaleNode

+ func (n *SideloadNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *SideloadNode) Last(field string) *InfluxQLNode

+ func (n *SideloadNode) Log() *LogNode

+ func (n *SideloadNode) MarshalJSON() ([]byte, error)

+ func (n *SideloadNode) Max(field string) *InfluxQLNode

+ func (n *SideloadNode) Mean(field string) *InfluxQLNode

+ func (n *SideloadNode) Median(field string) *InfluxQLNode

+ func (n *SideloadNode) Min(field string) *InfluxQLNode

+ func (n *SideloadNode) Mode(field string) *InfluxQLNode

+ func (n *SideloadNode) MovingAverage(field string, window int64) *InfluxQLNode

+ func (n *SideloadNode) Order(order ...string) *SideloadNode

+ func (n *SideloadNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *SideloadNode) Sample(rate interface{}) *SampleNode

+ func (n *SideloadNode) Shift(shift time.Duration) *ShiftNode

+ func (n *SideloadNode) Sideload() *SideloadNode

+ func (n *SideloadNode) Spread(field string) *InfluxQLNode

+ func (n *SideloadNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *SideloadNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

+ func (n *SideloadNode) Stddev(field string) *InfluxQLNode

+ func (n *SideloadNode) Sum(field string) *InfluxQLNode

+ func (n *SideloadNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *SideloadNode) Tag(t string, v string) *SideloadNode

+ func (n *SideloadNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *SideloadNode) Union(node ...Node) *UnionNode

+ func (n *SideloadNode) UnmarshalJSON(data []byte) error

+ func (n *SideloadNode) Where(expression *ast.LambdaNode) *WhereNode

+ func (n *SideloadNode) Window() *WindowNode

type SlackHandler

+ func (n SlackHandler) Barrier() *BarrierNode

+ func (n SlackHandler) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n SlackHandler) Sideload() *SideloadNode

+ func (n SlackHandler) SwarmAutoscale() *SwarmAutoscaleNode

type StateCountNode

+ func (n *StateCountNode) Barrier() *BarrierNode

+ func (n *StateCountNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *StateCountNode) MarshalJSON() ([]byte, error)

+ func (n *StateCountNode) Sideload() *SideloadNode

+ func (n *StateCountNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *StateCountNode) UnmarshalJSON(data []byte) error

type StateDurationNode

+ func (n *StateDurationNode) Barrier() *BarrierNode

+ func (n *StateDurationNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *StateDurationNode) MarshalJSON() ([]byte, error)

+ func (n *StateDurationNode) Sideload() *SideloadNode

+ func (n *StateDurationNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *StateDurationNode) UnmarshalJSON(data []byte) error

type StatsNode

+ func (n *StatsNode) Barrier() *BarrierNode

+ func (n *StatsNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *StatsNode) MarshalJSON() ([]byte, error)

+ func (n *StatsNode) Sideload() *SideloadNode

+ func (n *StatsNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *StatsNode) UnmarshalJSON(data []byte) error

type StreamNode

+ func (n *StreamNode) MarshalJSON() ([]byte, error)

+ func (n *StreamNode) UnmarshalJSON(data []byte) error

+ type SwarmAutoscaleNode struct

+ Cluster string

+ CurrentField string

+ DecreaseCooldown time.Duration

+ IncreaseCooldown time.Duration

+ Max int64

+ Min int64

+ OutputServiceNameTag string

+ Replicas *ast.LambdaNode

+ ServiceName string

+ ServiceNameTag string

+ func (n *SwarmAutoscaleNode) Alert() *AlertNode

+ func (n *SwarmAutoscaleNode) Barrier() *BarrierNode

+ func (n *SwarmAutoscaleNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *SwarmAutoscaleNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *SwarmAutoscaleNode) Count(field string) *InfluxQLNode

+ func (n *SwarmAutoscaleNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *SwarmAutoscaleNode) Default() *DefaultNode

+ func (n *SwarmAutoscaleNode) Delete() *DeleteNode

+ func (n *SwarmAutoscaleNode) Derivative(field string) *DerivativeNode

+ func (n *SwarmAutoscaleNode) Difference(field string) *InfluxQLNode

+ func (n *SwarmAutoscaleNode) Distinct(field string) *InfluxQLNode

+ func (n *SwarmAutoscaleNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *SwarmAutoscaleNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n *SwarmAutoscaleNode) Eval(expressions ...*ast.LambdaNode) *EvalNode

+ func (n *SwarmAutoscaleNode) First(field string) *InfluxQLNode

+ func (n *SwarmAutoscaleNode) Flatten() *FlattenNode

+ func (n *SwarmAutoscaleNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *SwarmAutoscaleNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *SwarmAutoscaleNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *SwarmAutoscaleNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *SwarmAutoscaleNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *SwarmAutoscaleNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *SwarmAutoscaleNode) Join(others ...Node) *JoinNode

+ func (n *SwarmAutoscaleNode) K8sAutoscale() *K8sAutoscaleNode

+ func (n *SwarmAutoscaleNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *SwarmAutoscaleNode) Last(field string) *InfluxQLNode

+ func (n *SwarmAutoscaleNode) Log() *LogNode

+ func (n *SwarmAutoscaleNode) MarshalJSON() ([]byte, error)

+ func (n *SwarmAutoscaleNode) Mean(field string) *InfluxQLNode

+ func (n *SwarmAutoscaleNode) Median(field string) *InfluxQLNode

+ func (n *SwarmAutoscaleNode) Mode(field string) *InfluxQLNode

+ func (n *SwarmAutoscaleNode) MovingAverage(field string, window int64) *InfluxQLNode

+ func (n *SwarmAutoscaleNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *SwarmAutoscaleNode) Sample(rate interface{}) *SampleNode

+ func (n *SwarmAutoscaleNode) Shift(shift time.Duration) *ShiftNode

+ func (n *SwarmAutoscaleNode) Sideload() *SideloadNode

+ func (n *SwarmAutoscaleNode) Spread(field string) *InfluxQLNode

+ func (n *SwarmAutoscaleNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *SwarmAutoscaleNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

+ func (n *SwarmAutoscaleNode) Stddev(field string) *InfluxQLNode

+ func (n *SwarmAutoscaleNode) Sum(field string) *InfluxQLNode

+ func (n *SwarmAutoscaleNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *SwarmAutoscaleNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *SwarmAutoscaleNode) Union(node ...Node) *UnionNode

+ func (n *SwarmAutoscaleNode) UnmarshalJSON(data []byte) error

+ func (n *SwarmAutoscaleNode) Where(expression *ast.LambdaNode) *WhereNode

+ func (n *SwarmAutoscaleNode) Window() *WindowNode

type TalkHandler

+ func (n TalkHandler) Barrier() *BarrierNode

+ func (n TalkHandler) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n TalkHandler) Sideload() *SideloadNode

+ func (n TalkHandler) SwarmAutoscale() *SwarmAutoscaleNode

type TcpHandler

+ func (n TcpHandler) Barrier() *BarrierNode

+ func (n TcpHandler) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n TcpHandler) Sideload() *SideloadNode

+ func (n TcpHandler) SwarmAutoscale() *SwarmAutoscaleNode

type TelegramHandler

+ func (n TelegramHandler) Barrier() *BarrierNode

+ func (n TelegramHandler) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n TelegramHandler) Sideload() *SideloadNode

+ func (n TelegramHandler) SwarmAutoscale() *SwarmAutoscaleNode

+ type TypeOf struct

+ ID ID

+ Type string

type UDFNode

+ func (n *UDFNode) Barrier() *BarrierNode

+ func (n *UDFNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *UDFNode) Sideload() *SideloadNode

+ func (n *UDFNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (u *UDFNode) MarshalJSON() ([]byte, error)

+ func (u *UDFNode) UnmarshalJSON(data []byte) error

type UnionNode

+ func (n *UnionNode) Barrier() *BarrierNode

+ func (n *UnionNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *UnionNode) MarshalJSON() ([]byte, error)

+ func (n *UnionNode) Sideload() *SideloadNode

+ func (n *UnionNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *UnionNode) UnmarshalJSON(data []byte) error

type VictorOpsHandler

+ func (n VictorOpsHandler) Barrier() *BarrierNode

+ func (n VictorOpsHandler) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n VictorOpsHandler) Sideload() *SideloadNode

+ func (n VictorOpsHandler) SwarmAutoscale() *SwarmAutoscaleNode

type WhereNode

+ func (n *WhereNode) Barrier() *BarrierNode

+ func (n *WhereNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *WhereNode) MarshalJSON() ([]byte, error)

+ func (n *WhereNode) Sideload() *SideloadNode

+ func (n *WhereNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *WhereNode) UnmarshalJSON(data []byte) error

type WindowNode

+ func (n *WindowNode) Barrier() *BarrierNode

+ func (n *WindowNode) Ec2Autoscale() *Ec2AutoscaleNode

+ func (n *WindowNode) MarshalJSON() ([]byte, error)

+ func (n *WindowNode) Sideload() *SideloadNode

+ func (n *WindowNode) SwarmAutoscale() *SwarmAutoscaleNode

+ func (n *WindowNode) UnmarshalJSON(data []byte) error

May 22, 2017

Changes in this version

+ type AlertHTTPPostHandler struct

+ Endpoint string

+ Headers map[string]string

+ URL string

+ func (a *AlertHTTPPostHandler) Header(k, v string) *AlertHTTPPostHandler

+ func (n AlertHTTPPostHandler) Alert() *AlertNode

+ func (n AlertHTTPPostHandler) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n AlertHTTPPostHandler) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n AlertHTTPPostHandler) Count(field string) *InfluxQLNode

+ func (n AlertHTTPPostHandler) CumulativeSum(field string) *InfluxQLNode

+ func (n AlertHTTPPostHandler) Default() *DefaultNode

+ func (n AlertHTTPPostHandler) Delete() *DeleteNode

+ func (n AlertHTTPPostHandler) Derivative(field string) *DerivativeNode

+ func (n AlertHTTPPostHandler) Difference(field string) *InfluxQLNode

+ func (n AlertHTTPPostHandler) Distinct(field string) *InfluxQLNode

+ func (n AlertHTTPPostHandler) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n AlertHTTPPostHandler) Eval(expressions ...*ast.LambdaNode) *EvalNode

+ func (n AlertHTTPPostHandler) First(field string) *InfluxQLNode

+ func (n AlertHTTPPostHandler) Flatten() *FlattenNode

+ func (n AlertHTTPPostHandler) GroupBy(tag ...interface{}) *GroupByNode

+ func (n AlertHTTPPostHandler) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n AlertHTTPPostHandler) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n AlertHTTPPostHandler) HttpOut(endpoint string) *HTTPOutNode

+ func (n AlertHTTPPostHandler) HttpPost(url ...string) *HTTPPostNode

+ func (n AlertHTTPPostHandler) InfluxDBOut() *InfluxDBOutNode

+ func (n AlertHTTPPostHandler) Join(others ...Node) *JoinNode

+ func (n AlertHTTPPostHandler) K8sAutoscale() *K8sAutoscaleNode

+ func (n AlertHTTPPostHandler) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n AlertHTTPPostHandler) Last(field string) *InfluxQLNode

+ func (n AlertHTTPPostHandler) Max(field string) *InfluxQLNode

+ func (n AlertHTTPPostHandler) Mean(field string) *InfluxQLNode

+ func (n AlertHTTPPostHandler) Median(field string) *InfluxQLNode

+ func (n AlertHTTPPostHandler) Min(field string) *InfluxQLNode

+ func (n AlertHTTPPostHandler) Mode(field string) *InfluxQLNode

+ func (n AlertHTTPPostHandler) MovingAverage(field string, window int64) *InfluxQLNode

+ func (n AlertHTTPPostHandler) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n AlertHTTPPostHandler) Sample(rate interface{}) *SampleNode

+ func (n AlertHTTPPostHandler) Shift(shift time.Duration) *ShiftNode

+ func (n AlertHTTPPostHandler) Spread(field string) *InfluxQLNode

+ func (n AlertHTTPPostHandler) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n AlertHTTPPostHandler) StateDuration(expression *ast.LambdaNode) *StateDurationNode

+ func (n AlertHTTPPostHandler) Stddev(field string) *InfluxQLNode

+ func (n AlertHTTPPostHandler) Sum(field string) *InfluxQLNode

+ func (n AlertHTTPPostHandler) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n AlertHTTPPostHandler) Union(node ...Node) *UnionNode

+ func (n AlertHTTPPostHandler) Where(expression *ast.LambdaNode) *WhereNode

+ func (n AlertHTTPPostHandler) Window() *WindowNode

type AlertNode

+ HTTPPostHandlers []*AlertHTTPPostHandler

+ PushoverHandlers []*PushoverHandler

+ func (a *AlertNode) Pushover() *PushoverHandler

+ func (n *AlertNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *AlertNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *AlertNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *AlertNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type AlertaHandler

+ func (n AlertaHandler) HttpPost(url ...string) *HTTPPostNode

+ func (n AlertaHandler) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n AlertaHandler) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n AlertaHandler) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type CombineNode

+ func (n *CombineNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *CombineNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *CombineNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *CombineNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type DefaultNode

+ func (n *DefaultNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *DefaultNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *DefaultNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *DefaultNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type DeleteNode

+ func (n *DeleteNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *DeleteNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *DeleteNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *DeleteNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type DerivativeNode

+ func (n *DerivativeNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *DerivativeNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *DerivativeNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *DerivativeNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type EmailHandler

+ func (n EmailHandler) HttpPost(url ...string) *HTTPPostNode

+ func (n EmailHandler) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n EmailHandler) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n EmailHandler) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type EvalNode

+ QuietFlag bool

+ func (n *EvalNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *EvalNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *EvalNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *EvalNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type ExecHandler

+ func (n ExecHandler) HttpPost(url ...string) *HTTPPostNode

+ func (n ExecHandler) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n ExecHandler) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n ExecHandler) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type FlattenNode

+ DropOriginalFieldNameFlag bool

+ func (f *FlattenNode) DropOriginalFieldName(drop ...bool) *FlattenNode

+ func (n *FlattenNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *FlattenNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *FlattenNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *FlattenNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type FromNode

+ func (n *FromNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *FromNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *FromNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *FromNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type GroupByNode

+ ExcludedDimensions []string

+ func (n *GroupByNode) Exclude(dims ...string) *GroupByNode

+ func (n *GroupByNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *GroupByNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *GroupByNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *GroupByNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type HTTPOutNode

+ func (n *HTTPOutNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *HTTPOutNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *HTTPOutNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *HTTPOutNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

+ type HTTPPostNode struct

+ Endpoints []string

+ Headers map[string]string

+ URLs []string

+ func (n *HTTPPostNode) Alert() *AlertNode

+ func (n *HTTPPostNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *HTTPPostNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *HTTPPostNode) Count(field string) *InfluxQLNode

+ func (n *HTTPPostNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *HTTPPostNode) Default() *DefaultNode

+ func (n *HTTPPostNode) Delete() *DeleteNode

+ func (n *HTTPPostNode) Derivative(field string) *DerivativeNode

+ func (n *HTTPPostNode) Difference(field string) *InfluxQLNode

+ func (n *HTTPPostNode) Distinct(field string) *InfluxQLNode

+ func (n *HTTPPostNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n *HTTPPostNode) Eval(expressions ...*ast.LambdaNode) *EvalNode

+ func (n *HTTPPostNode) First(field string) *InfluxQLNode

+ func (n *HTTPPostNode) Flatten() *FlattenNode

+ func (n *HTTPPostNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *HTTPPostNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *HTTPPostNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *HTTPPostNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *HTTPPostNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *HTTPPostNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *HTTPPostNode) Join(others ...Node) *JoinNode

+ func (n *HTTPPostNode) K8sAutoscale() *K8sAutoscaleNode

+ func (n *HTTPPostNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *HTTPPostNode) Last(field string) *InfluxQLNode

+ func (n *HTTPPostNode) Log() *LogNode

+ func (n *HTTPPostNode) Max(field string) *InfluxQLNode

+ func (n *HTTPPostNode) Mean(field string) *InfluxQLNode

+ func (n *HTTPPostNode) Median(field string) *InfluxQLNode

+ func (n *HTTPPostNode) Min(field string) *InfluxQLNode

+ func (n *HTTPPostNode) Mode(field string) *InfluxQLNode

+ func (n *HTTPPostNode) MovingAverage(field string, window int64) *InfluxQLNode

+ func (n *HTTPPostNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *HTTPPostNode) Sample(rate interface{}) *SampleNode

+ func (n *HTTPPostNode) Shift(shift time.Duration) *ShiftNode

+ func (n *HTTPPostNode) Spread(field string) *InfluxQLNode

+ func (n *HTTPPostNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *HTTPPostNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

+ func (n *HTTPPostNode) Stddev(field string) *InfluxQLNode

+ func (n *HTTPPostNode) Sum(field string) *InfluxQLNode

+ func (n *HTTPPostNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *HTTPPostNode) Union(node ...Node) *UnionNode

+ func (n *HTTPPostNode) Where(expression *ast.LambdaNode) *WhereNode

+ func (n *HTTPPostNode) Window() *WindowNode

+ func (p *HTTPPostNode) Endpoint(endpoint string) *HTTPPostNode

+ func (p *HTTPPostNode) Header(k, v string) *HTTPPostNode

type HipChatHandler

+ func (n HipChatHandler) HttpPost(url ...string) *HTTPPostNode

+ func (n HipChatHandler) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n HipChatHandler) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n HipChatHandler) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type InfluxQLNode

+ func (n *InfluxQLNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *InfluxQLNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *InfluxQLNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *InfluxQLNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type JoinNode

+ func (n *JoinNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *JoinNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *JoinNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *JoinNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type K8sAutoscaleNode

+ Cluster string

+ func (n *K8sAutoscaleNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *K8sAutoscaleNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *K8sAutoscaleNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *K8sAutoscaleNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

+ type KapacitorLoopbackNode struct

+ Database string

+ Measurement string

+ RetentionPolicy string

+ Tags map[string]string

+ func (k *KapacitorLoopbackNode) Tag(key, value string) *KapacitorLoopbackNode

+ func (n *KapacitorLoopbackNode) Children() []Node

+ func (n *KapacitorLoopbackNode) Deadman(threshold float64, interval time.Duration, expr ...*ast.LambdaNode) *AlertNode

+ func (n *KapacitorLoopbackNode) Desc() string

+ func (n *KapacitorLoopbackNode) ID() ID

+ func (n *KapacitorLoopbackNode) Name() string

+ func (n *KapacitorLoopbackNode) Parents() []Node

+ func (n *KapacitorLoopbackNode) Provides() EdgeType

+ func (n *KapacitorLoopbackNode) SetName(name string)

+ func (n *KapacitorLoopbackNode) Stats(interval time.Duration) *StatsNode

+ func (n *KapacitorLoopbackNode) Wants() EdgeType

type LogHandler

+ func (n LogHandler) HttpPost(url ...string) *HTTPPostNode

+ func (n LogHandler) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n LogHandler) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n LogHandler) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type LogNode

+ func (n *LogNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *LogNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *LogNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *LogNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type NoOpNode

+ func (n *NoOpNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *NoOpNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *NoOpNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *NoOpNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type OpsGenieHandler

+ func (n OpsGenieHandler) HttpPost(url ...string) *HTTPPostNode

+ func (n OpsGenieHandler) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n OpsGenieHandler) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n OpsGenieHandler) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type PagerDutyHandler

+ func (n PagerDutyHandler) HttpPost(url ...string) *HTTPPostNode

+ func (n PagerDutyHandler) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n PagerDutyHandler) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n PagerDutyHandler) StateDuration(expression *ast.LambdaNode) *StateDurationNode

+ type PushoverHandler struct

+ Device string

+ Sound string

+ Title string

+ URL string

+ URLTitle string

+ UserKey string

+ func (n PushoverHandler) Alert() *AlertNode

+ func (n PushoverHandler) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n PushoverHandler) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n PushoverHandler) Count(field string) *InfluxQLNode

+ func (n PushoverHandler) CumulativeSum(field string) *InfluxQLNode

+ func (n PushoverHandler) Default() *DefaultNode

+ func (n PushoverHandler) Delete() *DeleteNode

+ func (n PushoverHandler) Derivative(field string) *DerivativeNode

+ func (n PushoverHandler) Difference(field string) *InfluxQLNode

+ func (n PushoverHandler) Distinct(field string) *InfluxQLNode

+ func (n PushoverHandler) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n PushoverHandler) Eval(expressions ...*ast.LambdaNode) *EvalNode

+ func (n PushoverHandler) First(field string) *InfluxQLNode

+ func (n PushoverHandler) Flatten() *FlattenNode

+ func (n PushoverHandler) GroupBy(tag ...interface{}) *GroupByNode

+ func (n PushoverHandler) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n PushoverHandler) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n PushoverHandler) HttpOut(endpoint string) *HTTPOutNode

+ func (n PushoverHandler) HttpPost(url ...string) *HTTPPostNode

+ func (n PushoverHandler) InfluxDBOut() *InfluxDBOutNode

+ func (n PushoverHandler) Join(others ...Node) *JoinNode

+ func (n PushoverHandler) K8sAutoscale() *K8sAutoscaleNode

+ func (n PushoverHandler) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n PushoverHandler) Last(field string) *InfluxQLNode

+ func (n PushoverHandler) Max(field string) *InfluxQLNode

+ func (n PushoverHandler) Mean(field string) *InfluxQLNode

+ func (n PushoverHandler) Median(field string) *InfluxQLNode

+ func (n PushoverHandler) Min(field string) *InfluxQLNode

+ func (n PushoverHandler) Mode(field string) *InfluxQLNode

+ func (n PushoverHandler) MovingAverage(field string, window int64) *InfluxQLNode

+ func (n PushoverHandler) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n PushoverHandler) Sample(rate interface{}) *SampleNode

+ func (n PushoverHandler) Shift(shift time.Duration) *ShiftNode

+ func (n PushoverHandler) Spread(field string) *InfluxQLNode

+ func (n PushoverHandler) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n PushoverHandler) StateDuration(expression *ast.LambdaNode) *StateDurationNode

+ func (n PushoverHandler) Stddev(field string) *InfluxQLNode

+ func (n PushoverHandler) Sum(field string) *InfluxQLNode

+ func (n PushoverHandler) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n PushoverHandler) Union(node ...Node) *UnionNode

+ func (n PushoverHandler) Where(expression *ast.LambdaNode) *WhereNode

+ func (n PushoverHandler) Window() *WindowNode

type QueryNode

+ func (n *QueryNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *QueryNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *QueryNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *QueryNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type SNMPTrapHandler

+ func (n SNMPTrapHandler) HttpPost(url ...string) *HTTPPostNode

+ func (n SNMPTrapHandler) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n SNMPTrapHandler) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n SNMPTrapHandler) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type SampleNode

+ func (n *SampleNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *SampleNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *SampleNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *SampleNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type SensuHandler

+ HandlersList []string

+ Source string

+ func (n SensuHandler) HttpPost(url ...string) *HTTPPostNode

+ func (n SensuHandler) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n SensuHandler) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n SensuHandler) StateDuration(expression *ast.LambdaNode) *StateDurationNode

+ func (s *SensuHandler) Handlers(handlers ...string) *SensuHandler

type ShiftNode

+ func (n *ShiftNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *ShiftNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *ShiftNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *ShiftNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type SlackHandler

+ func (n SlackHandler) HttpPost(url ...string) *HTTPPostNode

+ func (n SlackHandler) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n SlackHandler) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n SlackHandler) StateDuration(expression *ast.LambdaNode) *StateDurationNode

+ type StateCountNode struct

+ As string

+ Lambda *ast.LambdaNode

+ func (n *StateCountNode) Alert() *AlertNode

+ func (n *StateCountNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *StateCountNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *StateCountNode) Count(field string) *InfluxQLNode

+ func (n *StateCountNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *StateCountNode) Default() *DefaultNode

+ func (n *StateCountNode) Delete() *DeleteNode

+ func (n *StateCountNode) Derivative(field string) *DerivativeNode

+ func (n *StateCountNode) Difference(field string) *InfluxQLNode

+ func (n *StateCountNode) Distinct(field string) *InfluxQLNode

+ func (n *StateCountNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n *StateCountNode) Eval(expressions ...*ast.LambdaNode) *EvalNode

+ func (n *StateCountNode) First(field string) *InfluxQLNode

+ func (n *StateCountNode) Flatten() *FlattenNode

+ func (n *StateCountNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *StateCountNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *StateCountNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *StateCountNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *StateCountNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *StateCountNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *StateCountNode) Join(others ...Node) *JoinNode

+ func (n *StateCountNode) K8sAutoscale() *K8sAutoscaleNode

+ func (n *StateCountNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *StateCountNode) Last(field string) *InfluxQLNode

+ func (n *StateCountNode) Log() *LogNode

+ func (n *StateCountNode) Max(field string) *InfluxQLNode

+ func (n *StateCountNode) Mean(field string) *InfluxQLNode

+ func (n *StateCountNode) Median(field string) *InfluxQLNode

+ func (n *StateCountNode) Min(field string) *InfluxQLNode

+ func (n *StateCountNode) Mode(field string) *InfluxQLNode

+ func (n *StateCountNode) MovingAverage(field string, window int64) *InfluxQLNode

+ func (n *StateCountNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *StateCountNode) Sample(rate interface{}) *SampleNode

+ func (n *StateCountNode) Shift(shift time.Duration) *ShiftNode

+ func (n *StateCountNode) Spread(field string) *InfluxQLNode

+ func (n *StateCountNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *StateCountNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

+ func (n *StateCountNode) Stddev(field string) *InfluxQLNode

+ func (n *StateCountNode) Sum(field string) *InfluxQLNode

+ func (n *StateCountNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *StateCountNode) Union(node ...Node) *UnionNode

+ func (n *StateCountNode) Where(expression *ast.LambdaNode) *WhereNode

+ func (n *StateCountNode) Window() *WindowNode

+ type StateDurationNode struct

+ As string

+ Lambda *ast.LambdaNode

+ Unit time.Duration

+ func (n *StateDurationNode) Alert() *AlertNode

+ func (n *StateDurationNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *StateDurationNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *StateDurationNode) Count(field string) *InfluxQLNode

+ func (n *StateDurationNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *StateDurationNode) Default() *DefaultNode

+ func (n *StateDurationNode) Delete() *DeleteNode

+ func (n *StateDurationNode) Derivative(field string) *DerivativeNode

+ func (n *StateDurationNode) Difference(field string) *InfluxQLNode

+ func (n *StateDurationNode) Distinct(field string) *InfluxQLNode

+ func (n *StateDurationNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n *StateDurationNode) Eval(expressions ...*ast.LambdaNode) *EvalNode

+ func (n *StateDurationNode) First(field string) *InfluxQLNode

+ func (n *StateDurationNode) Flatten() *FlattenNode

+ func (n *StateDurationNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *StateDurationNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *StateDurationNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *StateDurationNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *StateDurationNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *StateDurationNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *StateDurationNode) Join(others ...Node) *JoinNode

+ func (n *StateDurationNode) K8sAutoscale() *K8sAutoscaleNode

+ func (n *StateDurationNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *StateDurationNode) Last(field string) *InfluxQLNode

+ func (n *StateDurationNode) Log() *LogNode

+ func (n *StateDurationNode) Max(field string) *InfluxQLNode

+ func (n *StateDurationNode) Mean(field string) *InfluxQLNode

+ func (n *StateDurationNode) Median(field string) *InfluxQLNode

+ func (n *StateDurationNode) Min(field string) *InfluxQLNode

+ func (n *StateDurationNode) Mode(field string) *InfluxQLNode

+ func (n *StateDurationNode) MovingAverage(field string, window int64) *InfluxQLNode

+ func (n *StateDurationNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *StateDurationNode) Sample(rate interface{}) *SampleNode

+ func (n *StateDurationNode) Shift(shift time.Duration) *ShiftNode

+ func (n *StateDurationNode) Spread(field string) *InfluxQLNode

+ func (n *StateDurationNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *StateDurationNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

+ func (n *StateDurationNode) Stddev(field string) *InfluxQLNode

+ func (n *StateDurationNode) Sum(field string) *InfluxQLNode

+ func (n *StateDurationNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *StateDurationNode) Union(node ...Node) *UnionNode

+ func (n *StateDurationNode) Where(expression *ast.LambdaNode) *WhereNode

+ func (n *StateDurationNode) Window() *WindowNode

type StatsNode

+ func (n *StatsNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *StatsNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *StatsNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *StatsNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type TalkHandler

+ func (n TalkHandler) HttpPost(url ...string) *HTTPPostNode

+ func (n TalkHandler) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n TalkHandler) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n TalkHandler) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type TcpHandler

+ func (n TcpHandler) HttpPost(url ...string) *HTTPPostNode

+ func (n TcpHandler) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n TcpHandler) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n TcpHandler) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type TelegramHandler

+ func (n TelegramHandler) HttpPost(url ...string) *HTTPPostNode

+ func (n TelegramHandler) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n TelegramHandler) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n TelegramHandler) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type UDFNode

+ func (n *UDFNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *UDFNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *UDFNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *UDFNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type UnionNode

+ func (n *UnionNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *UnionNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *UnionNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *UnionNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type VictorOpsHandler

+ func (n VictorOpsHandler) HttpPost(url ...string) *HTTPPostNode

+ func (n VictorOpsHandler) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n VictorOpsHandler) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n VictorOpsHandler) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type WhereNode

+ func (n *WhereNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *WhereNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *WhereNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *WhereNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

type WindowNode

+ func (n *WindowNode) HttpPost(url ...string) *HTTPPostNode

+ func (n *WindowNode) KapacitorLoopback() *KapacitorLoopbackNode

+ func (n *WindowNode) StateCount(expression *ast.LambdaNode) *StateCountNode

+ func (n *WindowNode) StateDuration(expression *ast.LambdaNode) *StateDurationNode

Jan 23, 2017

Changes in this version

type AlertNode

+ SNMPTrapHandlers []*SNMPTrapHandler

+ Topic string

+ func (a *AlertNode) SnmpTrap(trapOid string) *SNMPTrapHandler

type QueryNode

+ AlignGroupFlag bool

+ func (b *QueryNode) AlignGroup() *QueryNode

+ type SNMPData struct

+ Oid string

+ Type string

+ Value string

+ type SNMPTrapHandler struct

+ DataList []SNMPData

+ TrapOid string

+ func (h *SNMPTrapHandler) Data(oid, typ, value string) *SNMPTrapHandler

+ func (n SNMPTrapHandler) Alert() *AlertNode

+ func (n SNMPTrapHandler) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n SNMPTrapHandler) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n SNMPTrapHandler) Count(field string) *InfluxQLNode

+ func (n SNMPTrapHandler) CumulativeSum(field string) *InfluxQLNode

+ func (n SNMPTrapHandler) Default() *DefaultNode

+ func (n SNMPTrapHandler) Delete() *DeleteNode

+ func (n SNMPTrapHandler) Derivative(field string) *DerivativeNode

+ func (n SNMPTrapHandler) Difference(field string) *InfluxQLNode

+ func (n SNMPTrapHandler) Distinct(field string) *InfluxQLNode

+ func (n SNMPTrapHandler) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n SNMPTrapHandler) Eval(expressions ...*ast.LambdaNode) *EvalNode

+ func (n SNMPTrapHandler) First(field string) *InfluxQLNode

+ func (n SNMPTrapHandler) Flatten() *FlattenNode

+ func (n SNMPTrapHandler) GroupBy(tag ...interface{}) *GroupByNode

+ func (n SNMPTrapHandler) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n SNMPTrapHandler) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n SNMPTrapHandler) HttpOut(endpoint string) *HTTPOutNode

+ func (n SNMPTrapHandler) InfluxDBOut() *InfluxDBOutNode

+ func (n SNMPTrapHandler) Join(others ...Node) *JoinNode

+ func (n SNMPTrapHandler) K8sAutoscale() *K8sAutoscaleNode

+ func (n SNMPTrapHandler) Last(field string) *InfluxQLNode

+ func (n SNMPTrapHandler) Max(field string) *InfluxQLNode

+ func (n SNMPTrapHandler) Mean(field string) *InfluxQLNode

+ func (n SNMPTrapHandler) Median(field string) *InfluxQLNode

+ func (n SNMPTrapHandler) Min(field string) *InfluxQLNode

+ func (n SNMPTrapHandler) Mode(field string) *InfluxQLNode

+ func (n SNMPTrapHandler) MovingAverage(field string, window int64) *InfluxQLNode

+ func (n SNMPTrapHandler) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n SNMPTrapHandler) Sample(rate interface{}) *SampleNode

+ func (n SNMPTrapHandler) Shift(shift time.Duration) *ShiftNode

+ func (n SNMPTrapHandler) Spread(field string) *InfluxQLNode

+ func (n SNMPTrapHandler) Stddev(field string) *InfluxQLNode

+ func (n SNMPTrapHandler) Sum(field string) *InfluxQLNode

+ func (n SNMPTrapHandler) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n SNMPTrapHandler) Union(node ...Node) *UnionNode

+ func (n SNMPTrapHandler) Where(expression *ast.LambdaNode) *WhereNode

+ func (n SNMPTrapHandler) Window() *WindowNode

type WindowNode

+ EveryCount int64

+ FillPeriodFlag bool

+ PeriodCount int64

+ func (w *WindowNode) FillPeriod() *WindowNode

Nov 7, 2016

Changes in this version

+ const DefaultKindTag

+ const DefaultNamespaceTag

+ const DefaultResourceTag

type AlertNode

+ func (n *AlertNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *AlertNode) K8sAutoscale() *K8sAutoscaleNode

type AlertaHandler

+ func (n AlertaHandler) CumulativeSum(field string) *InfluxQLNode

+ func (n AlertaHandler) K8sAutoscale() *K8sAutoscaleNode

type CombineNode

+ func (n *CombineNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *CombineNode) K8sAutoscale() *K8sAutoscaleNode

type DefaultNode

+ func (n *DefaultNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *DefaultNode) K8sAutoscale() *K8sAutoscaleNode

type DeleteNode

+ func (n *DeleteNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *DeleteNode) K8sAutoscale() *K8sAutoscaleNode

type DerivativeNode

+ func (n *DerivativeNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *DerivativeNode) K8sAutoscale() *K8sAutoscaleNode

type EmailHandler

+ func (n EmailHandler) CumulativeSum(field string) *InfluxQLNode

+ func (n EmailHandler) K8sAutoscale() *K8sAutoscaleNode

type EvalNode

+ func (n *EvalNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *EvalNode) K8sAutoscale() *K8sAutoscaleNode

type ExecHandler

+ func (n ExecHandler) CumulativeSum(field string) *InfluxQLNode

+ func (n ExecHandler) K8sAutoscale() *K8sAutoscaleNode

type FlattenNode

+ func (n *FlattenNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *FlattenNode) K8sAutoscale() *K8sAutoscaleNode

type FromNode

+ func (n *FromNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *FromNode) K8sAutoscale() *K8sAutoscaleNode

type GroupByNode

+ func (n *GroupByNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *GroupByNode) K8sAutoscale() *K8sAutoscaleNode

type HTTPOutNode

+ func (n *HTTPOutNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *HTTPOutNode) K8sAutoscale() *K8sAutoscaleNode

type HipChatHandler

+ func (n HipChatHandler) CumulativeSum(field string) *InfluxQLNode

+ func (n HipChatHandler) K8sAutoscale() *K8sAutoscaleNode

type InfluxQLNode

+ func (n *InfluxQLNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *InfluxQLNode) K8sAutoscale() *K8sAutoscaleNode

type JoinNode

+ func (n *JoinNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *JoinNode) K8sAutoscale() *K8sAutoscaleNode

+ type K8sAutoscaleNode struct

+ CurrentField string

+ DecreaseCooldown time.Duration

+ IncreaseCooldown time.Duration

+ Kind string

+ KindTag string

+ Max int64

+ Min int64

+ Namespace string

+ NamespaceTag string

+ Replicas *ast.LambdaNode

+ ResourceName string

+ ResourceNameTag string

+ ResourceTag string

+ func (n *K8sAutoscaleNode) Alert() *AlertNode

+ func (n *K8sAutoscaleNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *K8sAutoscaleNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *K8sAutoscaleNode) Count(field string) *InfluxQLNode

+ func (n *K8sAutoscaleNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *K8sAutoscaleNode) Default() *DefaultNode

+ func (n *K8sAutoscaleNode) Delete() *DeleteNode

+ func (n *K8sAutoscaleNode) Derivative(field string) *DerivativeNode

+ func (n *K8sAutoscaleNode) Difference(field string) *InfluxQLNode

+ func (n *K8sAutoscaleNode) Distinct(field string) *InfluxQLNode

+ func (n *K8sAutoscaleNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n *K8sAutoscaleNode) Eval(expressions ...*ast.LambdaNode) *EvalNode

+ func (n *K8sAutoscaleNode) First(field string) *InfluxQLNode

+ func (n *K8sAutoscaleNode) Flatten() *FlattenNode

+ func (n *K8sAutoscaleNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *K8sAutoscaleNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *K8sAutoscaleNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *K8sAutoscaleNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *K8sAutoscaleNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *K8sAutoscaleNode) Join(others ...Node) *JoinNode

+ func (n *K8sAutoscaleNode) K8sAutoscale() *K8sAutoscaleNode

+ func (n *K8sAutoscaleNode) Last(field string) *InfluxQLNode

+ func (n *K8sAutoscaleNode) Log() *LogNode

+ func (n *K8sAutoscaleNode) Mean(field string) *InfluxQLNode

+ func (n *K8sAutoscaleNode) Median(field string) *InfluxQLNode

+ func (n *K8sAutoscaleNode) Mode(field string) *InfluxQLNode

+ func (n *K8sAutoscaleNode) MovingAverage(field string, window int64) *InfluxQLNode

+ func (n *K8sAutoscaleNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *K8sAutoscaleNode) Sample(rate interface{}) *SampleNode

+ func (n *K8sAutoscaleNode) Shift(shift time.Duration) *ShiftNode

+ func (n *K8sAutoscaleNode) Spread(field string) *InfluxQLNode

+ func (n *K8sAutoscaleNode) Stddev(field string) *InfluxQLNode

+ func (n *K8sAutoscaleNode) Sum(field string) *InfluxQLNode

+ func (n *K8sAutoscaleNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *K8sAutoscaleNode) Union(node ...Node) *UnionNode

+ func (n *K8sAutoscaleNode) Where(expression *ast.LambdaNode) *WhereNode

+ func (n *K8sAutoscaleNode) Window() *WindowNode

type LogHandler

+ func (n LogHandler) CumulativeSum(field string) *InfluxQLNode

+ func (n LogHandler) K8sAutoscale() *K8sAutoscaleNode

type LogNode

+ func (n *LogNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *LogNode) K8sAutoscale() *K8sAutoscaleNode

type NoOpNode

+ func (n *NoOpNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *NoOpNode) K8sAutoscale() *K8sAutoscaleNode

type OpsGenieHandler

+ func (n OpsGenieHandler) CumulativeSum(field string) *InfluxQLNode

+ func (n OpsGenieHandler) K8sAutoscale() *K8sAutoscaleNode

type PagerDutyHandler

+ func (n PagerDutyHandler) CumulativeSum(field string) *InfluxQLNode

+ func (n PagerDutyHandler) K8sAutoscale() *K8sAutoscaleNode

type PostHandler

+ func (n PostHandler) CumulativeSum(field string) *InfluxQLNode

+ func (n PostHandler) K8sAutoscale() *K8sAutoscaleNode

type QueryNode

+ func (n *QueryNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *QueryNode) K8sAutoscale() *K8sAutoscaleNode

type SampleNode

+ func (n *SampleNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *SampleNode) K8sAutoscale() *K8sAutoscaleNode

type SensuHandler

+ func (n SensuHandler) CumulativeSum(field string) *InfluxQLNode

+ func (n SensuHandler) K8sAutoscale() *K8sAutoscaleNode

type ShiftNode

+ func (n *ShiftNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *ShiftNode) K8sAutoscale() *K8sAutoscaleNode

type SlackHandler

+ IconEmoji string

+ Username string

+ func (n SlackHandler) CumulativeSum(field string) *InfluxQLNode

+ func (n SlackHandler) K8sAutoscale() *K8sAutoscaleNode

type StatsNode

+ func (n *StatsNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *StatsNode) K8sAutoscale() *K8sAutoscaleNode

type TalkHandler

+ func (n TalkHandler) CumulativeSum(field string) *InfluxQLNode

+ func (n TalkHandler) K8sAutoscale() *K8sAutoscaleNode

type TcpHandler

+ func (n TcpHandler) CumulativeSum(field string) *InfluxQLNode

+ func (n TcpHandler) K8sAutoscale() *K8sAutoscaleNode

type TelegramHandler

+ func (n TelegramHandler) CumulativeSum(field string) *InfluxQLNode

+ func (n TelegramHandler) K8sAutoscale() *K8sAutoscaleNode

type UDFNode

+ func (n *UDFNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *UDFNode) K8sAutoscale() *K8sAutoscaleNode

type UnionNode

+ func (n *UnionNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *UnionNode) K8sAutoscale() *K8sAutoscaleNode

type VictorOpsHandler

+ func (n VictorOpsHandler) CumulativeSum(field string) *InfluxQLNode

+ func (n VictorOpsHandler) K8sAutoscale() *K8sAutoscaleNode

type WhereNode

+ func (n *WhereNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *WhereNode) K8sAutoscale() *K8sAutoscaleNode

type WindowNode

+ func (n *WindowNode) CumulativeSum(field string) *InfluxQLNode

+ func (n *WindowNode) K8sAutoscale() *K8sAutoscaleNode

Sep 26, 2016

Changes in this version

type AlertNode

+ MessageField string

+ TcpHandlers []*TcpHandler

+ func (a *AlertNode) Tcp(address string) *TcpHandler

type InfluxDBOutNode

+ CreateFlag bool

+ func (i *InfluxDBOutNode) Create() *InfluxDBOutNode

+ type TcpHandler struct

+ Address string

+ func (n TcpHandler) Alert() *AlertNode

+ func (n TcpHandler) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n TcpHandler) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n TcpHandler) Count(field string) *InfluxQLNode

+ func (n TcpHandler) Default() *DefaultNode

+ func (n TcpHandler) Delete() *DeleteNode

+ func (n TcpHandler) Derivative(field string) *DerivativeNode

+ func (n TcpHandler) Difference(field string) *InfluxQLNode

+ func (n TcpHandler) Distinct(field string) *InfluxQLNode

+ func (n TcpHandler) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n TcpHandler) Eval(expressions ...*ast.LambdaNode) *EvalNode

+ func (n TcpHandler) First(field string) *InfluxQLNode

+ func (n TcpHandler) Flatten() *FlattenNode

+ func (n TcpHandler) GroupBy(tag ...interface{}) *GroupByNode

+ func (n TcpHandler) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n TcpHandler) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n TcpHandler) HttpOut(endpoint string) *HTTPOutNode

+ func (n TcpHandler) InfluxDBOut() *InfluxDBOutNode

+ func (n TcpHandler) Join(others ...Node) *JoinNode

+ func (n TcpHandler) Last(field string) *InfluxQLNode

+ func (n TcpHandler) Max(field string) *InfluxQLNode

+ func (n TcpHandler) Mean(field string) *InfluxQLNode

+ func (n TcpHandler) Median(field string) *InfluxQLNode

+ func (n TcpHandler) Min(field string) *InfluxQLNode

+ func (n TcpHandler) Mode(field string) *InfluxQLNode

+ func (n TcpHandler) MovingAverage(field string, window int64) *InfluxQLNode

+ func (n TcpHandler) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n TcpHandler) Sample(rate interface{}) *SampleNode

+ func (n TcpHandler) Shift(shift time.Duration) *ShiftNode

+ func (n TcpHandler) Spread(field string) *InfluxQLNode

+ func (n TcpHandler) Stddev(field string) *InfluxQLNode

+ func (n TcpHandler) Sum(field string) *InfluxQLNode

+ func (n TcpHandler) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n TcpHandler) Union(node ...Node) *UnionNode

+ func (n TcpHandler) Where(expression *ast.LambdaNode) *WhereNode

+ func (n TcpHandler) Window() *WindowNode

Sep 2, 2016

Changes in this version

type AlertNode

+ CritReset *ast.LambdaNode

+ InfoReset *ast.LambdaNode

+ NoRecoveriesFlag bool

+ TelegramHandlers []*TelegramHandler

+ WarnReset *ast.LambdaNode

+ func (a *AlertNode) Telegram() *TelegramHandler

+ func (n *AlertNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *AlertNode) Delete() *DeleteNode

+ func (n *AlertNode) Difference(field string) *InfluxQLNode

+ func (n *AlertNode) Flatten() *FlattenNode

+ func (n *AlertNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *AlertNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *AlertNode) Mode(field string) *InfluxQLNode

+ func (n *AlertNode) MovingAverage(field string, window int64) *InfluxQLNode

+ func (n *AlertNode) NoRecoveries() *AlertNode

type AlertaHandler

+ func (n AlertaHandler) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n AlertaHandler) Delete() *DeleteNode

+ func (n AlertaHandler) Difference(field string) *InfluxQLNode

+ func (n AlertaHandler) Flatten() *FlattenNode

+ func (n AlertaHandler) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n AlertaHandler) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n AlertaHandler) Mode(field string) *InfluxQLNode

+ func (n AlertaHandler) MovingAverage(field string, window int64) *InfluxQLNode

+ type BooleanBulkPointAggregator interface

+ type CombineNode struct

+ Delimiter string

+ Lambdas []*ast.LambdaNode

+ Max int64

+ Names []string

+ Tolerance time.Duration

+ func (n *CombineNode) Alert() *AlertNode

+ func (n *CombineNode) As(names ...string) *CombineNode

+ func (n *CombineNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *CombineNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *CombineNode) Count(field string) *InfluxQLNode

+ func (n *CombineNode) Default() *DefaultNode

+ func (n *CombineNode) Delete() *DeleteNode

+ func (n *CombineNode) Derivative(field string) *DerivativeNode

+ func (n *CombineNode) Difference(field string) *InfluxQLNode

+ func (n *CombineNode) Distinct(field string) *InfluxQLNode

+ func (n *CombineNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n *CombineNode) Eval(expressions ...*ast.LambdaNode) *EvalNode

+ func (n *CombineNode) First(field string) *InfluxQLNode

+ func (n *CombineNode) Flatten() *FlattenNode

+ func (n *CombineNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *CombineNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *CombineNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *CombineNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *CombineNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *CombineNode) Join(others ...Node) *JoinNode

+ func (n *CombineNode) Last(field string) *InfluxQLNode

+ func (n *CombineNode) Log() *LogNode

+ func (n *CombineNode) Mean(field string) *InfluxQLNode

+ func (n *CombineNode) Median(field string) *InfluxQLNode

+ func (n *CombineNode) Min(field string) *InfluxQLNode

+ func (n *CombineNode) Mode(field string) *InfluxQLNode

+ func (n *CombineNode) MovingAverage(field string, window int64) *InfluxQLNode

+ func (n *CombineNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *CombineNode) Sample(rate interface{}) *SampleNode

+ func (n *CombineNode) Shift(shift time.Duration) *ShiftNode

+ func (n *CombineNode) Spread(field string) *InfluxQLNode

+ func (n *CombineNode) Stddev(field string) *InfluxQLNode

+ func (n *CombineNode) Sum(field string) *InfluxQLNode

+ func (n *CombineNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *CombineNode) Union(node ...Node) *UnionNode

+ func (n *CombineNode) Where(expression *ast.LambdaNode) *WhereNode

+ func (n *CombineNode) Window() *WindowNode

type DefaultNode

+ func (n *DefaultNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *DefaultNode) Delete() *DeleteNode

+ func (n *DefaultNode) Difference(field string) *InfluxQLNode

+ func (n *DefaultNode) Flatten() *FlattenNode

+ func (n *DefaultNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *DefaultNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *DefaultNode) Mode(field string) *InfluxQLNode

+ func (n *DefaultNode) MovingAverage(field string, window int64) *InfluxQLNode

+ type DeleteNode struct

+ Fields []string

+ Tags []string

+ func (n *DeleteNode) Alert() *AlertNode

+ func (n *DeleteNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *DeleteNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *DeleteNode) Count(field string) *InfluxQLNode

+ func (n *DeleteNode) Default() *DefaultNode

+ func (n *DeleteNode) Delete() *DeleteNode

+ func (n *DeleteNode) Derivative(field string) *DerivativeNode

+ func (n *DeleteNode) Difference(field string) *InfluxQLNode

+ func (n *DeleteNode) Distinct(field string) *InfluxQLNode

+ func (n *DeleteNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n *DeleteNode) Eval(expressions ...*ast.LambdaNode) *EvalNode

+ func (n *DeleteNode) Field(name string) *DeleteNode

+ func (n *DeleteNode) First(field string) *InfluxQLNode

+ func (n *DeleteNode) Flatten() *FlattenNode

+ func (n *DeleteNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *DeleteNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *DeleteNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *DeleteNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *DeleteNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *DeleteNode) Join(others ...Node) *JoinNode

+ func (n *DeleteNode) Last(field string) *InfluxQLNode

+ func (n *DeleteNode) Log() *LogNode

+ func (n *DeleteNode) Max(field string) *InfluxQLNode

+ func (n *DeleteNode) Mean(field string) *InfluxQLNode

+ func (n *DeleteNode) Median(field string) *InfluxQLNode

+ func (n *DeleteNode) Min(field string) *InfluxQLNode

+ func (n *DeleteNode) Mode(field string) *InfluxQLNode

+ func (n *DeleteNode) MovingAverage(field string, window int64) *InfluxQLNode

+ func (n *DeleteNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *DeleteNode) Sample(rate interface{}) *SampleNode

+ func (n *DeleteNode) Shift(shift time.Duration) *ShiftNode

+ func (n *DeleteNode) Spread(field string) *InfluxQLNode

+ func (n *DeleteNode) Stddev(field string) *InfluxQLNode

+ func (n *DeleteNode) Sum(field string) *InfluxQLNode

+ func (n *DeleteNode) Tag(name string) *DeleteNode

+ func (n *DeleteNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *DeleteNode) Union(node ...Node) *UnionNode

+ func (n *DeleteNode) Where(expression *ast.LambdaNode) *WhereNode

+ func (n *DeleteNode) Window() *WindowNode

type DerivativeNode

+ func (n *DerivativeNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *DerivativeNode) Delete() *DeleteNode

+ func (n *DerivativeNode) Difference(field string) *InfluxQLNode

+ func (n *DerivativeNode) Flatten() *FlattenNode

+ func (n *DerivativeNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *DerivativeNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *DerivativeNode) Mode(field string) *InfluxQLNode

+ func (n *DerivativeNode) MovingAverage(field string, window int64) *InfluxQLNode

type EmailHandler

+ func (h *EmailHandler) To(to ...string) *EmailHandler

+ func (n EmailHandler) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n EmailHandler) Delete() *DeleteNode

+ func (n EmailHandler) Difference(field string) *InfluxQLNode

+ func (n EmailHandler) Flatten() *FlattenNode

+ func (n EmailHandler) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n EmailHandler) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n EmailHandler) Mode(field string) *InfluxQLNode

+ func (n EmailHandler) MovingAverage(field string, window int64) *InfluxQLNode

type EvalNode

+ Lambdas []*ast.LambdaNode

+ TagsList []string

+ func (e *EvalNode) Tags(names ...string) *EvalNode

+ func (n *EvalNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *EvalNode) Delete() *DeleteNode

+ func (n *EvalNode) Difference(field string) *InfluxQLNode

+ func (n *EvalNode) Flatten() *FlattenNode

+ func (n *EvalNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *EvalNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *EvalNode) Mode(field string) *InfluxQLNode

+ func (n *EvalNode) MovingAverage(field string, window int64) *InfluxQLNode

type ExecHandler

+ func (n ExecHandler) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n ExecHandler) Delete() *DeleteNode

+ func (n ExecHandler) Difference(field string) *InfluxQLNode

+ func (n ExecHandler) Flatten() *FlattenNode

+ func (n ExecHandler) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n ExecHandler) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n ExecHandler) Mode(field string) *InfluxQLNode

+ func (n ExecHandler) MovingAverage(field string, window int64) *InfluxQLNode

+ type FlattenNode struct

+ Delimiter string

+ Dimensions []string

+ Tolerance time.Duration

+ func (f *FlattenNode) On(dims ...string) *FlattenNode

+ func (n *FlattenNode) Alert() *AlertNode

+ func (n *FlattenNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *FlattenNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *FlattenNode) Count(field string) *InfluxQLNode

+ func (n *FlattenNode) Default() *DefaultNode

+ func (n *FlattenNode) Delete() *DeleteNode

+ func (n *FlattenNode) Derivative(field string) *DerivativeNode

+ func (n *FlattenNode) Difference(field string) *InfluxQLNode

+ func (n *FlattenNode) Distinct(field string) *InfluxQLNode

+ func (n *FlattenNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n *FlattenNode) Eval(expressions ...*ast.LambdaNode) *EvalNode

+ func (n *FlattenNode) First(field string) *InfluxQLNode

+ func (n *FlattenNode) Flatten() *FlattenNode

+ func (n *FlattenNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *FlattenNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *FlattenNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *FlattenNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *FlattenNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *FlattenNode) Join(others ...Node) *JoinNode

+ func (n *FlattenNode) Last(field string) *InfluxQLNode

+ func (n *FlattenNode) Log() *LogNode

+ func (n *FlattenNode) Max(field string) *InfluxQLNode

+ func (n *FlattenNode) Mean(field string) *InfluxQLNode

+ func (n *FlattenNode) Median(field string) *InfluxQLNode

+ func (n *FlattenNode) Min(field string) *InfluxQLNode

+ func (n *FlattenNode) Mode(field string) *InfluxQLNode

+ func (n *FlattenNode) MovingAverage(field string, window int64) *InfluxQLNode

+ func (n *FlattenNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *FlattenNode) Sample(rate interface{}) *SampleNode

+ func (n *FlattenNode) Shift(shift time.Duration) *ShiftNode

+ func (n *FlattenNode) Spread(field string) *InfluxQLNode

+ func (n *FlattenNode) Stddev(field string) *InfluxQLNode

+ func (n *FlattenNode) Sum(field string) *InfluxQLNode

+ func (n *FlattenNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *FlattenNode) Union(node ...Node) *UnionNode

+ func (n *FlattenNode) Where(expression *ast.LambdaNode) *WhereNode

+ func (n *FlattenNode) Window() *WindowNode

type FromNode

+ GroupByMeasurementFlag bool

+ Lambda *ast.LambdaNode

+ Round time.Duration

+ func (n *FromNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *FromNode) Delete() *DeleteNode

+ func (n *FromNode) Difference(field string) *InfluxQLNode

+ func (n *FromNode) Flatten() *FlattenNode

+ func (n *FromNode) GroupByMeasurement() *FromNode

+ func (n *FromNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *FromNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *FromNode) Mode(field string) *InfluxQLNode

+ func (n *FromNode) MovingAverage(field string, window int64) *InfluxQLNode

type GroupByNode

+ ByMeasurementFlag bool

+ func (n *GroupByNode) ByMeasurement() *GroupByNode

+ func (n *GroupByNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *GroupByNode) Delete() *DeleteNode

+ func (n *GroupByNode) Difference(field string) *InfluxQLNode

+ func (n *GroupByNode) Flatten() *FlattenNode

+ func (n *GroupByNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *GroupByNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *GroupByNode) Mode(field string) *InfluxQLNode

+ func (n *GroupByNode) MovingAverage(field string, window int64) *InfluxQLNode

type HTTPOutNode

+ func (n *HTTPOutNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *HTTPOutNode) Delete() *DeleteNode

+ func (n *HTTPOutNode) Difference(field string) *InfluxQLNode

+ func (n *HTTPOutNode) Flatten() *FlattenNode

+ func (n *HTTPOutNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *HTTPOutNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *HTTPOutNode) Mode(field string) *InfluxQLNode

+ func (n *HTTPOutNode) MovingAverage(field string, window int64) *InfluxQLNode

type HipChatHandler

+ func (n HipChatHandler) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n HipChatHandler) Delete() *DeleteNode

+ func (n HipChatHandler) Difference(field string) *InfluxQLNode

+ func (n HipChatHandler) Flatten() *FlattenNode

+ func (n HipChatHandler) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n HipChatHandler) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n HipChatHandler) Mode(field string) *InfluxQLNode

+ func (n HipChatHandler) MovingAverage(field string, window int64) *InfluxQLNode

type InfluxQLNode

+ func (n *InfluxQLNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *InfluxQLNode) Delete() *DeleteNode

+ func (n *InfluxQLNode) Difference(field string) *InfluxQLNode

+ func (n *InfluxQLNode) Flatten() *FlattenNode

+ func (n *InfluxQLNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *InfluxQLNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *InfluxQLNode) Mode(field string) *InfluxQLNode

+ func (n *InfluxQLNode) MovingAverage(field string, window int64) *InfluxQLNode

type JoinNode

+ Delimiter string

+ func (n *JoinNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *JoinNode) Delete() *DeleteNode

+ func (n *JoinNode) Difference(field string) *InfluxQLNode

+ func (n *JoinNode) Flatten() *FlattenNode

+ func (n *JoinNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *JoinNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *JoinNode) Mode(field string) *InfluxQLNode

+ func (n *JoinNode) MovingAverage(field string, window int64) *InfluxQLNode

type LogHandler

+ func (n LogHandler) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n LogHandler) Delete() *DeleteNode

+ func (n LogHandler) Difference(field string) *InfluxQLNode

+ func (n LogHandler) Flatten() *FlattenNode

+ func (n LogHandler) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n LogHandler) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n LogHandler) MovingAverage(field string, window int64) *InfluxQLNode

type LogNode

+ func (n *LogNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *LogNode) Delete() *DeleteNode

+ func (n *LogNode) Difference(field string) *InfluxQLNode

+ func (n *LogNode) Flatten() *FlattenNode

+ func (n *LogNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *LogNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *LogNode) Mode(field string) *InfluxQLNode

+ func (n *LogNode) MovingAverage(field string, window int64) *InfluxQLNode

type NoOpNode

+ func (n *NoOpNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *NoOpNode) Delete() *DeleteNode

+ func (n *NoOpNode) Difference(field string) *InfluxQLNode

+ func (n *NoOpNode) Flatten() *FlattenNode

+ func (n *NoOpNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *NoOpNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *NoOpNode) Mode(field string) *InfluxQLNode

+ func (n *NoOpNode) MovingAverage(field string, window int64) *InfluxQLNode

type OpsGenieHandler

+ func (n OpsGenieHandler) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n OpsGenieHandler) Delete() *DeleteNode

+ func (n OpsGenieHandler) Difference(field string) *InfluxQLNode

+ func (n OpsGenieHandler) Flatten() *FlattenNode

+ func (n OpsGenieHandler) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n OpsGenieHandler) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n OpsGenieHandler) Mode(field string) *InfluxQLNode

+ func (n OpsGenieHandler) MovingAverage(field string, window int64) *InfluxQLNode

type PagerDutyHandler

+ ServiceKey string

+ func (n PagerDutyHandler) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n PagerDutyHandler) Delete() *DeleteNode

+ func (n PagerDutyHandler) Difference(field string) *InfluxQLNode

+ func (n PagerDutyHandler) Flatten() *FlattenNode

+ func (n PagerDutyHandler) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n PagerDutyHandler) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n PagerDutyHandler) Mode(field string) *InfluxQLNode

+ func (n PagerDutyHandler) MovingAverage(field string, window int64) *InfluxQLNode

type Pipeline

+ func (p *Pipeline) Len() int

type PostHandler

+ func (n PostHandler) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n PostHandler) Delete() *DeleteNode

+ func (n PostHandler) Difference(field string) *InfluxQLNode

+ func (n PostHandler) Flatten() *FlattenNode

+ func (n PostHandler) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n PostHandler) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n PostHandler) Mode(field string) *InfluxQLNode

+ func (n PostHandler) MovingAverage(field string, window int64) *InfluxQLNode

type QueryNode

+ GroupByMeasurementFlag bool

+ func (n *QueryNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *QueryNode) Delete() *DeleteNode

+ func (n *QueryNode) Difference(field string) *InfluxQLNode

+ func (n *QueryNode) Flatten() *FlattenNode

+ func (n *QueryNode) GroupByMeasurement() *QueryNode

+ func (n *QueryNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *QueryNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *QueryNode) Mode(field string) *InfluxQLNode

+ func (n *QueryNode) MovingAverage(field string, window int64) *InfluxQLNode

type ReduceCreater

+ CreateBooleanBulkFloatReducer func() (BooleanBulkPointAggregator, influxql.FloatPointEmitter)

+ CreateBooleanBulkIntegerReducer func() (BooleanBulkPointAggregator, influxql.IntegerPointEmitter)

+ CreateBooleanBulkReducer func() (BooleanBulkPointAggregator, influxql.BooleanPointEmitter)

+ CreateBooleanBulkStringReducer func() (BooleanBulkPointAggregator, influxql.StringPointEmitter)

+ CreateBooleanFloatReducer func() (influxql.BooleanPointAggregator, influxql.FloatPointEmitter)

+ CreateBooleanIntegerReducer func() (influxql.BooleanPointAggregator, influxql.IntegerPointEmitter)

+ CreateBooleanReducer func() (influxql.BooleanPointAggregator, influxql.BooleanPointEmitter)

+ CreateBooleanStringReducer func() (influxql.BooleanPointAggregator, influxql.StringPointEmitter)

+ CreateFloatBooleanReducer func() (influxql.FloatPointAggregator, influxql.BooleanPointEmitter)

+ CreateFloatBulkBooleanReducer func() (FloatBulkPointAggregator, influxql.BooleanPointEmitter)

+ CreateFloatBulkStringReducer func() (FloatBulkPointAggregator, influxql.StringPointEmitter)

+ CreateFloatStringReducer func() (influxql.FloatPointAggregator, influxql.StringPointEmitter)

+ CreateIntegerBooleanReducer func() (influxql.IntegerPointAggregator, influxql.BooleanPointEmitter)

+ CreateIntegerBulkBooleanReducer func() (IntegerBulkPointAggregator, influxql.BooleanPointEmitter)

+ CreateIntegerBulkStringReducer func() (IntegerBulkPointAggregator, influxql.StringPointEmitter)

+ CreateIntegerStringReducer func() (influxql.IntegerPointAggregator, influxql.StringPointEmitter)

+ CreateStringBooleanReducer func() (influxql.StringPointAggregator, influxql.BooleanPointEmitter)

+ CreateStringBulkBooleanReducer func() (StringBulkPointAggregator, influxql.BooleanPointEmitter)

+ CreateStringBulkFloatReducer func() (StringBulkPointAggregator, influxql.FloatPointEmitter)

+ CreateStringBulkIntegerReducer func() (StringBulkPointAggregator, influxql.IntegerPointEmitter)

+ CreateStringBulkReducer func() (StringBulkPointAggregator, influxql.StringPointEmitter)

+ CreateStringFloatReducer func() (influxql.StringPointAggregator, influxql.FloatPointEmitter)

+ CreateStringIntegerReducer func() (influxql.StringPointAggregator, influxql.IntegerPointEmitter)

+ CreateStringReducer func() (influxql.StringPointAggregator, influxql.StringPointEmitter)

+ IsEmptyOK bool

type SampleNode

+ func (n *SampleNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *SampleNode) Delete() *DeleteNode

+ func (n *SampleNode) Difference(field string) *InfluxQLNode

+ func (n *SampleNode) Flatten() *FlattenNode

+ func (n *SampleNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *SampleNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *SampleNode) Mode(field string) *InfluxQLNode

+ func (n *SampleNode) MovingAverage(field string, window int64) *InfluxQLNode

type SensuHandler

+ func (n SensuHandler) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n SensuHandler) Delete() *DeleteNode

+ func (n SensuHandler) Difference(field string) *InfluxQLNode

+ func (n SensuHandler) Flatten() *FlattenNode

+ func (n SensuHandler) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n SensuHandler) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n SensuHandler) Mode(field string) *InfluxQLNode

+ func (n SensuHandler) MovingAverage(field string, window int64) *InfluxQLNode

type ShiftNode

+ func (n *ShiftNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *ShiftNode) Delete() *DeleteNode

+ func (n *ShiftNode) Difference(field string) *InfluxQLNode

+ func (n *ShiftNode) Flatten() *FlattenNode

+ func (n *ShiftNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *ShiftNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *ShiftNode) Mode(field string) *InfluxQLNode

+ func (n *ShiftNode) MovingAverage(field string, window int64) *InfluxQLNode

type SlackHandler

+ func (n SlackHandler) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n SlackHandler) Delete() *DeleteNode

+ func (n SlackHandler) Difference(field string) *InfluxQLNode

+ func (n SlackHandler) Flatten() *FlattenNode

+ func (n SlackHandler) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n SlackHandler) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n SlackHandler) Mode(field string) *InfluxQLNode

+ func (n SlackHandler) MovingAverage(field string, window int64) *InfluxQLNode

type StatsNode

+ AlignFlag bool

+ func (n *StatsNode) Align() *StatsNode

+ func (n *StatsNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *StatsNode) Delete() *DeleteNode

+ func (n *StatsNode) Difference(field string) *InfluxQLNode

+ func (n *StatsNode) Flatten() *FlattenNode

+ func (n *StatsNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *StatsNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *StatsNode) Mode(field string) *InfluxQLNode

+ func (n *StatsNode) MovingAverage(field string, window int64) *InfluxQLNode

+ type StringBulkPointAggregator interface

type TalkHandler

+ func (n TalkHandler) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n TalkHandler) Delete() *DeleteNode

+ func (n TalkHandler) Difference(field string) *InfluxQLNode

+ func (n TalkHandler) Flatten() *FlattenNode

+ func (n TalkHandler) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n TalkHandler) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n TalkHandler) Mode(field string) *InfluxQLNode

+ func (n TalkHandler) MovingAverage(field string, window int64) *InfluxQLNode

+ type TelegramHandler struct

+ ChatId string

+ IsDisableNotification bool

+ IsDisableWebPagePreview bool

+ ParseMode string

+ func (n TelegramHandler) Alert() *AlertNode

+ func (n TelegramHandler) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n TelegramHandler) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n TelegramHandler) Count(field string) *InfluxQLNode

+ func (n TelegramHandler) Default() *DefaultNode

+ func (n TelegramHandler) Delete() *DeleteNode

+ func (n TelegramHandler) Derivative(field string) *DerivativeNode

+ func (n TelegramHandler) Difference(field string) *InfluxQLNode

+ func (n TelegramHandler) Distinct(field string) *InfluxQLNode

+ func (n TelegramHandler) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n TelegramHandler) Eval(expressions ...*ast.LambdaNode) *EvalNode

+ func (n TelegramHandler) First(field string) *InfluxQLNode

+ func (n TelegramHandler) Flatten() *FlattenNode

+ func (n TelegramHandler) GroupBy(tag ...interface{}) *GroupByNode

+ func (n TelegramHandler) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n TelegramHandler) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n TelegramHandler) HttpOut(endpoint string) *HTTPOutNode

+ func (n TelegramHandler) InfluxDBOut() *InfluxDBOutNode

+ func (n TelegramHandler) Join(others ...Node) *JoinNode

+ func (n TelegramHandler) Last(field string) *InfluxQLNode

+ func (n TelegramHandler) Max(field string) *InfluxQLNode

+ func (n TelegramHandler) Mean(field string) *InfluxQLNode

+ func (n TelegramHandler) Median(field string) *InfluxQLNode

+ func (n TelegramHandler) Min(field string) *InfluxQLNode

+ func (n TelegramHandler) Mode(field string) *InfluxQLNode

+ func (n TelegramHandler) MovingAverage(field string, window int64) *InfluxQLNode

+ func (n TelegramHandler) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n TelegramHandler) Sample(rate interface{}) *SampleNode

+ func (n TelegramHandler) Shift(shift time.Duration) *ShiftNode

+ func (n TelegramHandler) Spread(field string) *InfluxQLNode

+ func (n TelegramHandler) Stddev(field string) *InfluxQLNode

+ func (n TelegramHandler) Sum(field string) *InfluxQLNode

+ func (n TelegramHandler) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n TelegramHandler) Union(node ...Node) *UnionNode

+ func (n TelegramHandler) Where(expression *ast.LambdaNode) *WhereNode

+ func (n TelegramHandler) Window() *WindowNode

+ func (tel *TelegramHandler) DisableNotification() *TelegramHandler

+ func (tel *TelegramHandler) DisableWebPagePreview() *TelegramHandler

+ type TemplatePipeline struct

+ func CreateTemplatePipeline(script string, sourceEdge EdgeType, scope *stateful.Scope, ...) (*TemplatePipeline, error)

+ func (t *TemplatePipeline) Dot(name string) []byte

+ func (t *TemplatePipeline) Vars() map[string]tick.Var

type UDFNode

+ func (n *UDFNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *UDFNode) Delete() *DeleteNode

+ func (n *UDFNode) Difference(field string) *InfluxQLNode

+ func (n *UDFNode) Flatten() *FlattenNode

+ func (n *UDFNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *UDFNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *UDFNode) Mode(field string) *InfluxQLNode

+ func (n *UDFNode) MovingAverage(field string, window int64) *InfluxQLNode

type UnionNode

+ func (n *UnionNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *UnionNode) Delete() *DeleteNode

+ func (n *UnionNode) Difference(field string) *InfluxQLNode

+ func (n *UnionNode) Flatten() *FlattenNode

+ func (n *UnionNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *UnionNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *UnionNode) Mode(field string) *InfluxQLNode

+ func (n *UnionNode) MovingAverage(field string, window int64) *InfluxQLNode

type VictorOpsHandler

+ func (n VictorOpsHandler) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n VictorOpsHandler) Delete() *DeleteNode

+ func (n VictorOpsHandler) Difference(field string) *InfluxQLNode

+ func (n VictorOpsHandler) Flatten() *FlattenNode

+ func (n VictorOpsHandler) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n VictorOpsHandler) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n VictorOpsHandler) Mode(field string) *InfluxQLNode

+ func (n VictorOpsHandler) MovingAverage(field string, window int64) *InfluxQLNode

type WhereNode

+ Lambda *ast.LambdaNode

+ func (n *WhereNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *WhereNode) Delete() *DeleteNode

+ func (n *WhereNode) Difference(field string) *InfluxQLNode

+ func (n *WhereNode) Flatten() *FlattenNode

+ func (n *WhereNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *WhereNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *WhereNode) Mode(field string) *InfluxQLNode

+ func (n *WhereNode) MovingAverage(field string, window int64) *InfluxQLNode

type WindowNode

+ func (n *WindowNode) Combine(expressions ...*ast.LambdaNode) *CombineNode

+ func (n *WindowNode) Delete() *DeleteNode

+ func (n *WindowNode) Difference(field string) *InfluxQLNode

+ func (n *WindowNode) Flatten() *FlattenNode

+ func (n *WindowNode) HoltWinters(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *WindowNode) HoltWintersWithFit(field string, h, m int64, interval time.Duration) *InfluxQLNode

+ func (n *WindowNode) Mode(field string) *InfluxQLNode

+ func (n *WindowNode) MovingAverage(field string, window int64) *InfluxQLNode

May 12, 2016

Changes in this version

type AlertNode

+ AllFlag bool

+ DurationField string

+ IdField string

+ IdTag string

+ LevelField string

+ LevelTag string

+ StateChangesOnlyDuration time.Duration

+ func (n *AlertNode) Alert() *AlertNode

+ func (n *AlertNode) All() *AlertNode

+ func (n *AlertNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *AlertNode) ChainMethods() map[string]reflect.Value

+ func (n *AlertNode) Count(field string) *InfluxQLNode

+ func (n *AlertNode) Default() *DefaultNode

+ func (n *AlertNode) Derivative(field string) *DerivativeNode

+ func (n *AlertNode) Distinct(field string) *InfluxQLNode

+ func (n *AlertNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n *AlertNode) Eval(expressions ...tick.Node) *EvalNode

+ func (n *AlertNode) First(field string) *InfluxQLNode

+ func (n *AlertNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *AlertNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *AlertNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *AlertNode) Join(others ...Node) *JoinNode

+ func (n *AlertNode) Last(field string) *InfluxQLNode

+ func (n *AlertNode) Max(field string) *InfluxQLNode

+ func (n *AlertNode) Mean(field string) *InfluxQLNode

+ func (n *AlertNode) Median(field string) *InfluxQLNode

+ func (n *AlertNode) Min(field string) *InfluxQLNode

+ func (n *AlertNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *AlertNode) Sample(rate interface{}) *SampleNode

+ func (n *AlertNode) Shift(shift time.Duration) *ShiftNode

+ func (n *AlertNode) Spread(field string) *InfluxQLNode

+ func (n *AlertNode) Stddev(field string) *InfluxQLNode

+ func (n *AlertNode) Sum(field string) *InfluxQLNode

+ func (n *AlertNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *AlertNode) Union(node ...Node) *UnionNode

+ func (n *AlertNode) Where(expression tick.Node) *WhereNode

+ func (n *AlertNode) Window() *WindowNode

type AlertaHandler

+ func (n AlertaHandler) Alert() *AlertNode

+ func (n AlertaHandler) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n AlertaHandler) Count(field string) *InfluxQLNode

+ func (n AlertaHandler) Default() *DefaultNode

+ func (n AlertaHandler) Derivative(field string) *DerivativeNode

+ func (n AlertaHandler) Distinct(field string) *InfluxQLNode

+ func (n AlertaHandler) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n AlertaHandler) Eval(expressions ...tick.Node) *EvalNode

+ func (n AlertaHandler) First(field string) *InfluxQLNode

+ func (n AlertaHandler) GroupBy(tag ...interface{}) *GroupByNode

+ func (n AlertaHandler) HttpOut(endpoint string) *HTTPOutNode

+ func (n AlertaHandler) InfluxDBOut() *InfluxDBOutNode

+ func (n AlertaHandler) Join(others ...Node) *JoinNode

+ func (n AlertaHandler) Last(field string) *InfluxQLNode

+ func (n AlertaHandler) Max(field string) *InfluxQLNode

+ func (n AlertaHandler) Mean(field string) *InfluxQLNode

+ func (n AlertaHandler) Median(field string) *InfluxQLNode

+ func (n AlertaHandler) Min(field string) *InfluxQLNode

+ func (n AlertaHandler) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n AlertaHandler) Sample(rate interface{}) *SampleNode

+ func (n AlertaHandler) Shift(shift time.Duration) *ShiftNode

+ func (n AlertaHandler) Spread(field string) *InfluxQLNode

+ func (n AlertaHandler) Stddev(field string) *InfluxQLNode

+ func (n AlertaHandler) Sum(field string) *InfluxQLNode

+ func (n AlertaHandler) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n AlertaHandler) Union(node ...Node) *UnionNode

+ func (n AlertaHandler) Where(expression tick.Node) *WhereNode

+ func (n AlertaHandler) Window() *WindowNode

type BatchNode

+ func (b *BatchNode) Query(q string) *QueryNode

+ func (n *BatchNode) Children() []Node

+ func (n *BatchNode) Deadman(threshold float64, interval time.Duration, expr ...tick.Node) *AlertNode

+ func (n *BatchNode) ID() ID

+ func (n *BatchNode) Name() string

+ func (n *BatchNode) Parents() []Node

+ func (n *BatchNode) Provides() EdgeType

+ func (n *BatchNode) SetName(name string)

+ func (n *BatchNode) Stats(interval time.Duration) *StatsNode

+ func (n *BatchNode) Wants() EdgeType

+ type DefaultNode struct

+ Fields map[string]interface{}

+ Tags map[string]string

+ func (n *DefaultNode) Alert() *AlertNode

+ func (n *DefaultNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *DefaultNode) Count(field string) *InfluxQLNode

+ func (n *DefaultNode) Default() *DefaultNode

+ func (n *DefaultNode) Derivative(field string) *DerivativeNode

+ func (n *DefaultNode) Distinct(field string) *InfluxQLNode

+ func (n *DefaultNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n *DefaultNode) Eval(expressions ...tick.Node) *EvalNode

+ func (n *DefaultNode) Field(name string, value interface{}) *DefaultNode

+ func (n *DefaultNode) First(field string) *InfluxQLNode

+ func (n *DefaultNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *DefaultNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *DefaultNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *DefaultNode) Join(others ...Node) *JoinNode

+ func (n *DefaultNode) Last(field string) *InfluxQLNode

+ func (n *DefaultNode) Log() *LogNode

+ func (n *DefaultNode) Max(field string) *InfluxQLNode

+ func (n *DefaultNode) Mean(field string) *InfluxQLNode

+ func (n *DefaultNode) Median(field string) *InfluxQLNode

+ func (n *DefaultNode) Min(field string) *InfluxQLNode

+ func (n *DefaultNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *DefaultNode) Sample(rate interface{}) *SampleNode

+ func (n *DefaultNode) Shift(shift time.Duration) *ShiftNode

+ func (n *DefaultNode) Spread(field string) *InfluxQLNode

+ func (n *DefaultNode) Stddev(field string) *InfluxQLNode

+ func (n *DefaultNode) Sum(field string) *InfluxQLNode

+ func (n *DefaultNode) Tag(name string, value string) *DefaultNode

+ func (n *DefaultNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *DefaultNode) Union(node ...Node) *UnionNode

+ func (n *DefaultNode) Where(expression tick.Node) *WhereNode

+ func (n *DefaultNode) Window() *WindowNode

type DerivativeNode

+ func (n *DerivativeNode) Default() *DefaultNode

+ func (n *DerivativeNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

type EmailHandler

+ func (n EmailHandler) Alert() *AlertNode

+ func (n EmailHandler) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n EmailHandler) Count(field string) *InfluxQLNode

+ func (n EmailHandler) Default() *DefaultNode

+ func (n EmailHandler) Derivative(field string) *DerivativeNode

+ func (n EmailHandler) Distinct(field string) *InfluxQLNode

+ func (n EmailHandler) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n EmailHandler) Eval(expressions ...tick.Node) *EvalNode

+ func (n EmailHandler) First(field string) *InfluxQLNode

+ func (n EmailHandler) GroupBy(tag ...interface{}) *GroupByNode

+ func (n EmailHandler) HttpOut(endpoint string) *HTTPOutNode

+ func (n EmailHandler) InfluxDBOut() *InfluxDBOutNode

+ func (n EmailHandler) Join(others ...Node) *JoinNode

+ func (n EmailHandler) Last(field string) *InfluxQLNode

+ func (n EmailHandler) Max(field string) *InfluxQLNode

+ func (n EmailHandler) Mean(field string) *InfluxQLNode

+ func (n EmailHandler) Median(field string) *InfluxQLNode

+ func (n EmailHandler) Min(field string) *InfluxQLNode

+ func (n EmailHandler) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n EmailHandler) Sample(rate interface{}) *SampleNode

+ func (n EmailHandler) Shift(shift time.Duration) *ShiftNode

+ func (n EmailHandler) Spread(field string) *InfluxQLNode

+ func (n EmailHandler) Stddev(field string) *InfluxQLNode

+ func (n EmailHandler) Sum(field string) *InfluxQLNode

+ func (n EmailHandler) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n EmailHandler) Union(node ...Node) *UnionNode

+ func (n EmailHandler) Where(expression tick.Node) *WhereNode

+ func (n EmailHandler) Window() *WindowNode

type EvalNode

+ func (n *EvalNode) Default() *DefaultNode

+ func (n *EvalNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

type ExecHandler

+ func (n ExecHandler) Alert() *AlertNode

+ func (n ExecHandler) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n ExecHandler) Count(field string) *InfluxQLNode

+ func (n ExecHandler) Default() *DefaultNode

+ func (n ExecHandler) Derivative(field string) *DerivativeNode

+ func (n ExecHandler) Distinct(field string) *InfluxQLNode

+ func (n ExecHandler) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n ExecHandler) Eval(expressions ...tick.Node) *EvalNode

+ func (n ExecHandler) First(field string) *InfluxQLNode

+ func (n ExecHandler) GroupBy(tag ...interface{}) *GroupByNode

+ func (n ExecHandler) HttpOut(endpoint string) *HTTPOutNode

+ func (n ExecHandler) InfluxDBOut() *InfluxDBOutNode

+ func (n ExecHandler) Join(others ...Node) *JoinNode

+ func (n ExecHandler) Last(field string) *InfluxQLNode

+ func (n ExecHandler) Max(field string) *InfluxQLNode

+ func (n ExecHandler) Mean(field string) *InfluxQLNode

+ func (n ExecHandler) Median(field string) *InfluxQLNode

+ func (n ExecHandler) Min(field string) *InfluxQLNode

+ func (n ExecHandler) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n ExecHandler) Sample(rate interface{}) *SampleNode

+ func (n ExecHandler) Shift(shift time.Duration) *ShiftNode

+ func (n ExecHandler) Spread(field string) *InfluxQLNode

+ func (n ExecHandler) Stddev(field string) *InfluxQLNode

+ func (n ExecHandler) Sum(field string) *InfluxQLNode

+ func (n ExecHandler) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n ExecHandler) Union(node ...Node) *UnionNode

+ func (n ExecHandler) Where(expression tick.Node) *WhereNode

+ func (n ExecHandler) Window() *WindowNode

+ type FromNode struct

+ Database string

+ Dimensions []interface{}

+ Expression tick.Node

+ Measurement string

+ RetentionPolicy string

+ Truncate time.Duration

+ func (n *FromNode) Alert() *AlertNode

+ func (n *FromNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *FromNode) ChainMethods() map[string]reflect.Value

+ func (n *FromNode) Count(field string) *InfluxQLNode

+ func (n *FromNode) Default() *DefaultNode

+ func (n *FromNode) Derivative(field string) *DerivativeNode

+ func (n *FromNode) Distinct(field string) *InfluxQLNode

+ func (n *FromNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n *FromNode) Eval(expressions ...tick.Node) *EvalNode

+ func (n *FromNode) First(field string) *InfluxQLNode

+ func (n *FromNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *FromNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *FromNode) Join(others ...Node) *JoinNode

+ func (n *FromNode) Last(field string) *InfluxQLNode

+ func (n *FromNode) Log() *LogNode

+ func (n *FromNode) Max(field string) *InfluxQLNode

+ func (n *FromNode) Mean(field string) *InfluxQLNode

+ func (n *FromNode) Median(field string) *InfluxQLNode

+ func (n *FromNode) Min(field string) *InfluxQLNode

+ func (n *FromNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *FromNode) Sample(rate interface{}) *SampleNode

+ func (n *FromNode) Shift(shift time.Duration) *ShiftNode

+ func (n *FromNode) Spread(field string) *InfluxQLNode

+ func (n *FromNode) Stddev(field string) *InfluxQLNode

+ func (n *FromNode) Sum(field string) *InfluxQLNode

+ func (n *FromNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *FromNode) Union(node ...Node) *UnionNode

+ func (n *FromNode) Window() *WindowNode

+ func (s *FromNode) From() *FromNode

+ func (s *FromNode) GroupBy(tag ...interface{}) *FromNode

+ func (s *FromNode) Where(expression tick.Node) *FromNode

type GroupByNode

+ func (n *GroupByNode) Default() *DefaultNode

+ func (n *GroupByNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

type HTTPOutNode

+ func (n *HTTPOutNode) Default() *DefaultNode

+ func (n *HTTPOutNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

type HipChatHandler

+ func (n HipChatHandler) Alert() *AlertNode

+ func (n HipChatHandler) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n HipChatHandler) Count(field string) *InfluxQLNode

+ func (n HipChatHandler) Default() *DefaultNode

+ func (n HipChatHandler) Derivative(field string) *DerivativeNode

+ func (n HipChatHandler) Distinct(field string) *InfluxQLNode

+ func (n HipChatHandler) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n HipChatHandler) Eval(expressions ...tick.Node) *EvalNode

+ func (n HipChatHandler) First(field string) *InfluxQLNode

+ func (n HipChatHandler) GroupBy(tag ...interface{}) *GroupByNode

+ func (n HipChatHandler) HttpOut(endpoint string) *HTTPOutNode

+ func (n HipChatHandler) InfluxDBOut() *InfluxDBOutNode

+ func (n HipChatHandler) Join(others ...Node) *JoinNode

+ func (n HipChatHandler) Last(field string) *InfluxQLNode

+ func (n HipChatHandler) Max(field string) *InfluxQLNode

+ func (n HipChatHandler) Mean(field string) *InfluxQLNode

+ func (n HipChatHandler) Median(field string) *InfluxQLNode

+ func (n HipChatHandler) Min(field string) *InfluxQLNode

+ func (n HipChatHandler) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n HipChatHandler) Sample(rate interface{}) *SampleNode

+ func (n HipChatHandler) Shift(shift time.Duration) *ShiftNode

+ func (n HipChatHandler) Spread(field string) *InfluxQLNode

+ func (n HipChatHandler) Stddev(field string) *InfluxQLNode

+ func (n HipChatHandler) Sum(field string) *InfluxQLNode

+ func (n HipChatHandler) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n HipChatHandler) Union(node ...Node) *UnionNode

+ func (n HipChatHandler) Where(expression tick.Node) *WhereNode

+ func (n HipChatHandler) Window() *WindowNode

type InfluxQLNode

+ func (n *InfluxQLNode) Default() *DefaultNode

+ func (n *InfluxQLNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

type JoinNode

+ func (n *JoinNode) Default() *DefaultNode

+ func (n *JoinNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

type LogHandler

+ func (n LogHandler) Alert() *AlertNode

+ func (n LogHandler) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n LogHandler) Count(field string) *InfluxQLNode

+ func (n LogHandler) Default() *DefaultNode

+ func (n LogHandler) Derivative(field string) *DerivativeNode

+ func (n LogHandler) Distinct(field string) *InfluxQLNode

+ func (n LogHandler) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n LogHandler) Eval(expressions ...tick.Node) *EvalNode

+ func (n LogHandler) First(field string) *InfluxQLNode

+ func (n LogHandler) GroupBy(tag ...interface{}) *GroupByNode

+ func (n LogHandler) HttpOut(endpoint string) *HTTPOutNode

+ func (n LogHandler) InfluxDBOut() *InfluxDBOutNode

+ func (n LogHandler) Join(others ...Node) *JoinNode

+ func (n LogHandler) Last(field string) *InfluxQLNode

+ func (n LogHandler) Max(field string) *InfluxQLNode

+ func (n LogHandler) Mean(field string) *InfluxQLNode

+ func (n LogHandler) Median(field string) *InfluxQLNode

+ func (n LogHandler) Min(field string) *InfluxQLNode

+ func (n LogHandler) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n LogHandler) Sample(rate interface{}) *SampleNode

+ func (n LogHandler) Shift(shift time.Duration) *ShiftNode

+ func (n LogHandler) Spread(field string) *InfluxQLNode

+ func (n LogHandler) Stddev(field string) *InfluxQLNode

+ func (n LogHandler) Sum(field string) *InfluxQLNode

+ func (n LogHandler) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n LogHandler) Union(node ...Node) *UnionNode

+ func (n LogHandler) Where(expression tick.Node) *WhereNode

+ func (n LogHandler) Window() *WindowNode

type LogNode

+ func (n *LogNode) Default() *DefaultNode

+ func (n *LogNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

type NoOpNode

+ func (n *NoOpNode) Default() *DefaultNode

+ func (n *NoOpNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

type OpsGenieHandler

+ func (n OpsGenieHandler) Alert() *AlertNode

+ func (n OpsGenieHandler) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n OpsGenieHandler) Count(field string) *InfluxQLNode

+ func (n OpsGenieHandler) Default() *DefaultNode

+ func (n OpsGenieHandler) Derivative(field string) *DerivativeNode

+ func (n OpsGenieHandler) Distinct(field string) *InfluxQLNode

+ func (n OpsGenieHandler) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n OpsGenieHandler) Eval(expressions ...tick.Node) *EvalNode

+ func (n OpsGenieHandler) First(field string) *InfluxQLNode

+ func (n OpsGenieHandler) GroupBy(tag ...interface{}) *GroupByNode

+ func (n OpsGenieHandler) HttpOut(endpoint string) *HTTPOutNode

+ func (n OpsGenieHandler) InfluxDBOut() *InfluxDBOutNode

+ func (n OpsGenieHandler) Join(others ...Node) *JoinNode

+ func (n OpsGenieHandler) Last(field string) *InfluxQLNode

+ func (n OpsGenieHandler) Max(field string) *InfluxQLNode

+ func (n OpsGenieHandler) Mean(field string) *InfluxQLNode

+ func (n OpsGenieHandler) Median(field string) *InfluxQLNode

+ func (n OpsGenieHandler) Min(field string) *InfluxQLNode

+ func (n OpsGenieHandler) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n OpsGenieHandler) Sample(rate interface{}) *SampleNode

+ func (n OpsGenieHandler) Shift(shift time.Duration) *ShiftNode

+ func (n OpsGenieHandler) Spread(field string) *InfluxQLNode

+ func (n OpsGenieHandler) Stddev(field string) *InfluxQLNode

+ func (n OpsGenieHandler) Sum(field string) *InfluxQLNode

+ func (n OpsGenieHandler) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n OpsGenieHandler) Union(node ...Node) *UnionNode

+ func (n OpsGenieHandler) Where(expression tick.Node) *WhereNode

+ func (n OpsGenieHandler) Window() *WindowNode

type PagerDutyHandler

+ func (n PagerDutyHandler) Alert() *AlertNode

+ func (n PagerDutyHandler) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n PagerDutyHandler) Count(field string) *InfluxQLNode

+ func (n PagerDutyHandler) Default() *DefaultNode

+ func (n PagerDutyHandler) Derivative(field string) *DerivativeNode

+ func (n PagerDutyHandler) Distinct(field string) *InfluxQLNode

+ func (n PagerDutyHandler) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n PagerDutyHandler) Eval(expressions ...tick.Node) *EvalNode

+ func (n PagerDutyHandler) First(field string) *InfluxQLNode

+ func (n PagerDutyHandler) GroupBy(tag ...interface{}) *GroupByNode

+ func (n PagerDutyHandler) HttpOut(endpoint string) *HTTPOutNode

+ func (n PagerDutyHandler) InfluxDBOut() *InfluxDBOutNode

+ func (n PagerDutyHandler) Join(others ...Node) *JoinNode

+ func (n PagerDutyHandler) Last(field string) *InfluxQLNode

+ func (n PagerDutyHandler) Max(field string) *InfluxQLNode

+ func (n PagerDutyHandler) Mean(field string) *InfluxQLNode

+ func (n PagerDutyHandler) Median(field string) *InfluxQLNode

+ func (n PagerDutyHandler) Min(field string) *InfluxQLNode

+ func (n PagerDutyHandler) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n PagerDutyHandler) Sample(rate interface{}) *SampleNode

+ func (n PagerDutyHandler) Shift(shift time.Duration) *ShiftNode

+ func (n PagerDutyHandler) Spread(field string) *InfluxQLNode

+ func (n PagerDutyHandler) Stddev(field string) *InfluxQLNode

+ func (n PagerDutyHandler) Sum(field string) *InfluxQLNode

+ func (n PagerDutyHandler) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n PagerDutyHandler) Union(node ...Node) *UnionNode

+ func (n PagerDutyHandler) Where(expression tick.Node) *WhereNode

+ func (n PagerDutyHandler) Window() *WindowNode

type PostHandler

+ func (n PostHandler) Alert() *AlertNode

+ func (n PostHandler) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n PostHandler) Count(field string) *InfluxQLNode

+ func (n PostHandler) Default() *DefaultNode

+ func (n PostHandler) Derivative(field string) *DerivativeNode

+ func (n PostHandler) Distinct(field string) *InfluxQLNode

+ func (n PostHandler) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n PostHandler) Eval(expressions ...tick.Node) *EvalNode

+ func (n PostHandler) First(field string) *InfluxQLNode

+ func (n PostHandler) GroupBy(tag ...interface{}) *GroupByNode

+ func (n PostHandler) HttpOut(endpoint string) *HTTPOutNode

+ func (n PostHandler) InfluxDBOut() *InfluxDBOutNode

+ func (n PostHandler) Join(others ...Node) *JoinNode

+ func (n PostHandler) Last(field string) *InfluxQLNode

+ func (n PostHandler) Max(field string) *InfluxQLNode

+ func (n PostHandler) Mean(field string) *InfluxQLNode

+ func (n PostHandler) Median(field string) *InfluxQLNode

+ func (n PostHandler) Min(field string) *InfluxQLNode

+ func (n PostHandler) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n PostHandler) Sample(rate interface{}) *SampleNode

+ func (n PostHandler) Shift(shift time.Duration) *ShiftNode

+ func (n PostHandler) Spread(field string) *InfluxQLNode

+ func (n PostHandler) Stddev(field string) *InfluxQLNode

+ func (n PostHandler) Sum(field string) *InfluxQLNode

+ func (n PostHandler) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n PostHandler) Union(node ...Node) *UnionNode

+ func (n PostHandler) Where(expression tick.Node) *WhereNode

+ func (n PostHandler) Window() *WindowNode

+ type QueryNode struct

+ AlignFlag bool

+ Cluster string

+ Cron string

+ Dimensions []interface{}

+ Every time.Duration

+ Fill interface{}

+ Offset time.Duration

+ Period time.Duration

+ QueryStr string

+ func (b *QueryNode) Align() *QueryNode

+ func (b *QueryNode) GroupBy(d ...interface{}) *QueryNode

+ func (n *QueryNode) Alert() *AlertNode

+ func (n *QueryNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *QueryNode) ChainMethods() map[string]reflect.Value

+ func (n *QueryNode) Count(field string) *InfluxQLNode

+ func (n *QueryNode) Default() *DefaultNode

+ func (n *QueryNode) Derivative(field string) *DerivativeNode

+ func (n *QueryNode) Distinct(field string) *InfluxQLNode

+ func (n *QueryNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n *QueryNode) Eval(expressions ...tick.Node) *EvalNode

+ func (n *QueryNode) First(field string) *InfluxQLNode

+ func (n *QueryNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *QueryNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *QueryNode) Join(others ...Node) *JoinNode

+ func (n *QueryNode) Last(field string) *InfluxQLNode

+ func (n *QueryNode) Log() *LogNode

+ func (n *QueryNode) Max(field string) *InfluxQLNode

+ func (n *QueryNode) Mean(field string) *InfluxQLNode

+ func (n *QueryNode) Median(field string) *InfluxQLNode

+ func (n *QueryNode) Min(field string) *InfluxQLNode

+ func (n *QueryNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *QueryNode) Sample(rate interface{}) *SampleNode

+ func (n *QueryNode) Shift(shift time.Duration) *ShiftNode

+ func (n *QueryNode) Spread(field string) *InfluxQLNode

+ func (n *QueryNode) Stddev(field string) *InfluxQLNode

+ func (n *QueryNode) Sum(field string) *InfluxQLNode

+ func (n *QueryNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *QueryNode) Union(node ...Node) *UnionNode

+ func (n *QueryNode) Where(expression tick.Node) *WhereNode

+ func (n *QueryNode) Window() *WindowNode

type ReduceCreater

+ IsSimpleSelector bool

+ IsStreamTransformation bool

type SampleNode

+ func (n *SampleNode) Default() *DefaultNode

+ func (n *SampleNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

type SensuHandler

+ func (n SensuHandler) Alert() *AlertNode

+ func (n SensuHandler) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n SensuHandler) Count(field string) *InfluxQLNode

+ func (n SensuHandler) Default() *DefaultNode

+ func (n SensuHandler) Derivative(field string) *DerivativeNode

+ func (n SensuHandler) Distinct(field string) *InfluxQLNode

+ func (n SensuHandler) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n SensuHandler) Eval(expressions ...tick.Node) *EvalNode

+ func (n SensuHandler) First(field string) *InfluxQLNode

+ func (n SensuHandler) GroupBy(tag ...interface{}) *GroupByNode

+ func (n SensuHandler) HttpOut(endpoint string) *HTTPOutNode

+ func (n SensuHandler) InfluxDBOut() *InfluxDBOutNode

+ func (n SensuHandler) Join(others ...Node) *JoinNode

+ func (n SensuHandler) Last(field string) *InfluxQLNode

+ func (n SensuHandler) Max(field string) *InfluxQLNode

+ func (n SensuHandler) Mean(field string) *InfluxQLNode

+ func (n SensuHandler) Median(field string) *InfluxQLNode

+ func (n SensuHandler) Min(field string) *InfluxQLNode

+ func (n SensuHandler) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n SensuHandler) Sample(rate interface{}) *SampleNode

+ func (n SensuHandler) Shift(shift time.Duration) *ShiftNode

+ func (n SensuHandler) Spread(field string) *InfluxQLNode

+ func (n SensuHandler) Stddev(field string) *InfluxQLNode

+ func (n SensuHandler) Sum(field string) *InfluxQLNode

+ func (n SensuHandler) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n SensuHandler) Union(node ...Node) *UnionNode

+ func (n SensuHandler) Where(expression tick.Node) *WhereNode

+ func (n SensuHandler) Window() *WindowNode

type ShiftNode

+ func (n *ShiftNode) Default() *DefaultNode

+ func (n *ShiftNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

type SlackHandler

+ func (n SlackHandler) Alert() *AlertNode

+ func (n SlackHandler) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n SlackHandler) Count(field string) *InfluxQLNode

+ func (n SlackHandler) Default() *DefaultNode

+ func (n SlackHandler) Derivative(field string) *DerivativeNode

+ func (n SlackHandler) Distinct(field string) *InfluxQLNode

+ func (n SlackHandler) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n SlackHandler) Eval(expressions ...tick.Node) *EvalNode

+ func (n SlackHandler) First(field string) *InfluxQLNode

+ func (n SlackHandler) GroupBy(tag ...interface{}) *GroupByNode

+ func (n SlackHandler) HttpOut(endpoint string) *HTTPOutNode

+ func (n SlackHandler) InfluxDBOut() *InfluxDBOutNode

+ func (n SlackHandler) Join(others ...Node) *JoinNode

+ func (n SlackHandler) Last(field string) *InfluxQLNode

+ func (n SlackHandler) Max(field string) *InfluxQLNode

+ func (n SlackHandler) Mean(field string) *InfluxQLNode

+ func (n SlackHandler) Median(field string) *InfluxQLNode

+ func (n SlackHandler) Min(field string) *InfluxQLNode

+ func (n SlackHandler) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n SlackHandler) Sample(rate interface{}) *SampleNode

+ func (n SlackHandler) Shift(shift time.Duration) *ShiftNode

+ func (n SlackHandler) Spread(field string) *InfluxQLNode

+ func (n SlackHandler) Stddev(field string) *InfluxQLNode

+ func (n SlackHandler) Sum(field string) *InfluxQLNode

+ func (n SlackHandler) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n SlackHandler) Union(node ...Node) *UnionNode

+ func (n SlackHandler) Where(expression tick.Node) *WhereNode

+ func (n SlackHandler) Window() *WindowNode

type StatsNode

+ func (n *StatsNode) Default() *DefaultNode

+ func (n *StatsNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

type StreamNode

+ func (n *StreamNode) Children() []Node

+ func (n *StreamNode) Deadman(threshold float64, interval time.Duration, expr ...tick.Node) *AlertNode

+ func (n *StreamNode) Desc() string

+ func (n *StreamNode) ID() ID

+ func (n *StreamNode) Name() string

+ func (n *StreamNode) Parents() []Node

+ func (n *StreamNode) Provides() EdgeType

+ func (n *StreamNode) SetName(name string)

+ func (n *StreamNode) Stats(interval time.Duration) *StatsNode

+ func (n *StreamNode) Wants() EdgeType

type TalkHandler

+ func (n TalkHandler) Alert() *AlertNode

+ func (n TalkHandler) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n TalkHandler) Count(field string) *InfluxQLNode

+ func (n TalkHandler) Default() *DefaultNode

+ func (n TalkHandler) Derivative(field string) *DerivativeNode

+ func (n TalkHandler) Distinct(field string) *InfluxQLNode

+ func (n TalkHandler) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n TalkHandler) Eval(expressions ...tick.Node) *EvalNode

+ func (n TalkHandler) First(field string) *InfluxQLNode

+ func (n TalkHandler) GroupBy(tag ...interface{}) *GroupByNode

+ func (n TalkHandler) HttpOut(endpoint string) *HTTPOutNode

+ func (n TalkHandler) InfluxDBOut() *InfluxDBOutNode

+ func (n TalkHandler) Join(others ...Node) *JoinNode

+ func (n TalkHandler) Last(field string) *InfluxQLNode

+ func (n TalkHandler) Max(field string) *InfluxQLNode

+ func (n TalkHandler) Mean(field string) *InfluxQLNode

+ func (n TalkHandler) Median(field string) *InfluxQLNode

+ func (n TalkHandler) Min(field string) *InfluxQLNode

+ func (n TalkHandler) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n TalkHandler) Sample(rate interface{}) *SampleNode

+ func (n TalkHandler) Shift(shift time.Duration) *ShiftNode

+ func (n TalkHandler) Spread(field string) *InfluxQLNode

+ func (n TalkHandler) Stddev(field string) *InfluxQLNode

+ func (n TalkHandler) Sum(field string) *InfluxQLNode

+ func (n TalkHandler) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n TalkHandler) Union(node ...Node) *UnionNode

+ func (n TalkHandler) Where(expression tick.Node) *WhereNode

+ func (n TalkHandler) Window() *WindowNode

type UDFNode

+ UDFName string

+ func (n *UDFNode) Default() *DefaultNode

+ func (n *UDFNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

type UnionNode

+ func (n *UnionNode) Default() *DefaultNode

+ func (n *UnionNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

type VictorOpsHandler

+ func (n VictorOpsHandler) Alert() *AlertNode

+ func (n VictorOpsHandler) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n VictorOpsHandler) Count(field string) *InfluxQLNode

+ func (n VictorOpsHandler) Default() *DefaultNode

+ func (n VictorOpsHandler) Derivative(field string) *DerivativeNode

+ func (n VictorOpsHandler) Distinct(field string) *InfluxQLNode

+ func (n VictorOpsHandler) Elapsed(field string, unit time.Duration) *InfluxQLNode

+ func (n VictorOpsHandler) Eval(expressions ...tick.Node) *EvalNode

+ func (n VictorOpsHandler) First(field string) *InfluxQLNode

+ func (n VictorOpsHandler) GroupBy(tag ...interface{}) *GroupByNode

+ func (n VictorOpsHandler) HttpOut(endpoint string) *HTTPOutNode

+ func (n VictorOpsHandler) InfluxDBOut() *InfluxDBOutNode

+ func (n VictorOpsHandler) Join(others ...Node) *JoinNode

+ func (n VictorOpsHandler) Last(field string) *InfluxQLNode

+ func (n VictorOpsHandler) Max(field string) *InfluxQLNode

+ func (n VictorOpsHandler) Mean(field string) *InfluxQLNode

+ func (n VictorOpsHandler) Median(field string) *InfluxQLNode

+ func (n VictorOpsHandler) Min(field string) *InfluxQLNode

+ func (n VictorOpsHandler) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n VictorOpsHandler) Sample(rate interface{}) *SampleNode

+ func (n VictorOpsHandler) Shift(shift time.Duration) *ShiftNode

+ func (n VictorOpsHandler) Spread(field string) *InfluxQLNode

+ func (n VictorOpsHandler) Stddev(field string) *InfluxQLNode

+ func (n VictorOpsHandler) Sum(field string) *InfluxQLNode

+ func (n VictorOpsHandler) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n VictorOpsHandler) Union(node ...Node) *UnionNode

+ func (n VictorOpsHandler) Where(expression tick.Node) *WhereNode

+ func (n VictorOpsHandler) Window() *WindowNode

type WhereNode

+ func (n *WhereNode) Default() *DefaultNode

+ func (n *WhereNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

type WindowNode

+ func (n *WindowNode) Default() *DefaultNode

+ func (n *WindowNode) Elapsed(field string, unit time.Duration) *InfluxQLNode

Apr 4, 2016

Changes in this version

type BatchNode

+ AlignFlag bool

+ func (b *BatchNode) Align() *BatchNode

+ func (b *BatchNode) CallChainMethod(name string, args ...interface{}) (interface{}, error)

+ func (b *BatchNode) Desc() string

+ func (b *BatchNode) HasChainMethod(name string) bool

+ func (b *BatchNode) HasProperty(name string) bool

+ func (b *BatchNode) Property(name string) interface{}

+ func (b *BatchNode) SetProperty(name string, args ...interface{}) (interface{}, error)

type EvalNode

+ QuiteFlag bool

+ func (e *EvalNode) Quiet() *EvalNode

type LogHandler

+ Mode int64

type SampleNode

+ N int64

type UDFNode

+ func (u *UDFNode) CallChainMethod(name string, args ...interface{}) (interface{}, error)

+ func (u *UDFNode) HasChainMethod(name string) bool

Mar 22, 2016

Changes in this version

+ const DefaultBufferSize

+ const DefaultFlushInterval

type AlertaHandler

+ Service []string

+ func (a *AlertaHandler) Services(service ...string) *AlertaHandler

type BatchNode

+ Cluster string

+ func (n *BatchNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *BatchNode) Count(field string) *InfluxQLNode

+ func (n *BatchNode) Distinct(field string) *InfluxQLNode

+ func (n *BatchNode) First(field string) *InfluxQLNode

+ func (n *BatchNode) Last(field string) *InfluxQLNode

+ func (n *BatchNode) Log() *LogNode

+ func (n *BatchNode) Max(field string) *InfluxQLNode

+ func (n *BatchNode) Mean(field string) *InfluxQLNode

+ func (n *BatchNode) Median(field string) *InfluxQLNode

+ func (n *BatchNode) Min(field string) *InfluxQLNode

+ func (n *BatchNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *BatchNode) Shift(shift time.Duration) *ShiftNode

+ func (n *BatchNode) Spread(field string) *InfluxQLNode

+ func (n *BatchNode) Stddev(field string) *InfluxQLNode

+ func (n *BatchNode) Sum(field string) *InfluxQLNode

+ func (n *BatchNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

type DerivativeNode

+ func (n *DerivativeNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *DerivativeNode) Count(field string) *InfluxQLNode

+ func (n *DerivativeNode) Distinct(field string) *InfluxQLNode

+ func (n *DerivativeNode) First(field string) *InfluxQLNode

+ func (n *DerivativeNode) Last(field string) *InfluxQLNode

+ func (n *DerivativeNode) Log() *LogNode

+ func (n *DerivativeNode) Max(field string) *InfluxQLNode

+ func (n *DerivativeNode) Mean(field string) *InfluxQLNode

+ func (n *DerivativeNode) Median(field string) *InfluxQLNode

+ func (n *DerivativeNode) Min(field string) *InfluxQLNode

+ func (n *DerivativeNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *DerivativeNode) Shift(shift time.Duration) *ShiftNode

+ func (n *DerivativeNode) Spread(field string) *InfluxQLNode

+ func (n *DerivativeNode) Stddev(field string) *InfluxQLNode

+ func (n *DerivativeNode) Sum(field string) *InfluxQLNode

+ func (n *DerivativeNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

type EvalNode

+ func (n *EvalNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *EvalNode) Count(field string) *InfluxQLNode

+ func (n *EvalNode) Distinct(field string) *InfluxQLNode

+ func (n *EvalNode) First(field string) *InfluxQLNode

+ func (n *EvalNode) Last(field string) *InfluxQLNode

+ func (n *EvalNode) Log() *LogNode

+ func (n *EvalNode) Max(field string) *InfluxQLNode

+ func (n *EvalNode) Mean(field string) *InfluxQLNode

+ func (n *EvalNode) Median(field string) *InfluxQLNode

+ func (n *EvalNode) Min(field string) *InfluxQLNode

+ func (n *EvalNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *EvalNode) Shift(shift time.Duration) *ShiftNode

+ func (n *EvalNode) Spread(field string) *InfluxQLNode

+ func (n *EvalNode) Stddev(field string) *InfluxQLNode

+ func (n *EvalNode) Sum(field string) *InfluxQLNode

+ func (n *EvalNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ type FloatBulkPointAggregator interface

type GroupByNode

+ func (n *GroupByNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *GroupByNode) Count(field string) *InfluxQLNode

+ func (n *GroupByNode) Distinct(field string) *InfluxQLNode

+ func (n *GroupByNode) First(field string) *InfluxQLNode

+ func (n *GroupByNode) Last(field string) *InfluxQLNode

+ func (n *GroupByNode) Log() *LogNode

+ func (n *GroupByNode) Max(field string) *InfluxQLNode

+ func (n *GroupByNode) Mean(field string) *InfluxQLNode

+ func (n *GroupByNode) Median(field string) *InfluxQLNode

+ func (n *GroupByNode) Min(field string) *InfluxQLNode

+ func (n *GroupByNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *GroupByNode) Shift(shift time.Duration) *ShiftNode

+ func (n *GroupByNode) Spread(field string) *InfluxQLNode

+ func (n *GroupByNode) Stddev(field string) *InfluxQLNode

+ func (n *GroupByNode) Sum(field string) *InfluxQLNode

+ func (n *GroupByNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

type HTTPOutNode

+ func (n *HTTPOutNode) Alert() *AlertNode

+ func (n *HTTPOutNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *HTTPOutNode) Count(field string) *InfluxQLNode

+ func (n *HTTPOutNode) Derivative(field string) *DerivativeNode

+ func (n *HTTPOutNode) Distinct(field string) *InfluxQLNode

+ func (n *HTTPOutNode) Eval(expressions ...tick.Node) *EvalNode

+ func (n *HTTPOutNode) First(field string) *InfluxQLNode

+ func (n *HTTPOutNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *HTTPOutNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *HTTPOutNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *HTTPOutNode) Join(others ...Node) *JoinNode

+ func (n *HTTPOutNode) Last(field string) *InfluxQLNode

+ func (n *HTTPOutNode) Log() *LogNode

+ func (n *HTTPOutNode) MapReduce(mr MapReduceInfo) *ReduceNode

+ func (n *HTTPOutNode) Max(field string) *InfluxQLNode

+ func (n *HTTPOutNode) Mean(field string) *InfluxQLNode

+ func (n *HTTPOutNode) Median(field string) *InfluxQLNode

+ func (n *HTTPOutNode) Min(field string) *InfluxQLNode

+ func (n *HTTPOutNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *HTTPOutNode) Sample(rate interface{}) *SampleNode

+ func (n *HTTPOutNode) Shift(shift time.Duration) *ShiftNode

+ func (n *HTTPOutNode) Spread(field string) *InfluxQLNode

+ func (n *HTTPOutNode) Stddev(field string) *InfluxQLNode

+ func (n *HTTPOutNode) Sum(field string) *InfluxQLNode

+ func (n *HTTPOutNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *HTTPOutNode) Union(node ...Node) *UnionNode

+ func (n *HTTPOutNode) Where(expression tick.Node) *WhereNode

+ func (n *HTTPOutNode) Window() *WindowNode

type InfluxDBOutNode

+ Buffer int64

+ Cluster string

+ FlushInterval time.Duration

+ type InfluxQLNode struct

+ As string

+ Field string

+ Method string

+ PointTimes bool

+ ReduceCreater ReduceCreater

+ func (n *InfluxQLNode) Alert() *AlertNode

+ func (n *InfluxQLNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *InfluxQLNode) Count(field string) *InfluxQLNode

+ func (n *InfluxQLNode) Derivative(field string) *DerivativeNode

+ func (n *InfluxQLNode) Distinct(field string) *InfluxQLNode

+ func (n *InfluxQLNode) Eval(expressions ...tick.Node) *EvalNode

+ func (n *InfluxQLNode) First(field string) *InfluxQLNode

+ func (n *InfluxQLNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *InfluxQLNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *InfluxQLNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *InfluxQLNode) Join(others ...Node) *JoinNode

+ func (n *InfluxQLNode) Last(field string) *InfluxQLNode

+ func (n *InfluxQLNode) Log() *LogNode

+ func (n *InfluxQLNode) MapReduce(mr MapReduceInfo) *ReduceNode

+ func (n *InfluxQLNode) Max(field string) *InfluxQLNode

+ func (n *InfluxQLNode) Mean(field string) *InfluxQLNode

+ func (n *InfluxQLNode) Median(field string) *InfluxQLNode

+ func (n *InfluxQLNode) Min(field string) *InfluxQLNode

+ func (n *InfluxQLNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *InfluxQLNode) Sample(rate interface{}) *SampleNode

+ func (n *InfluxQLNode) Shift(shift time.Duration) *ShiftNode

+ func (n *InfluxQLNode) Spread(field string) *InfluxQLNode

+ func (n *InfluxQLNode) Stddev(field string) *InfluxQLNode

+ func (n *InfluxQLNode) Sum(field string) *InfluxQLNode

+ func (n *InfluxQLNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *InfluxQLNode) Union(node ...Node) *UnionNode

+ func (n *InfluxQLNode) UsePointTimes() *InfluxQLNode

+ func (n *InfluxQLNode) Where(expression tick.Node) *WhereNode

+ func (n *InfluxQLNode) Window() *WindowNode

+ type IntegerBulkPointAggregator interface

type JoinNode

+ Dimensions []string

+ func (j *JoinNode) On(dims ...string) *JoinNode

+ func (n *JoinNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *JoinNode) Count(field string) *InfluxQLNode

+ func (n *JoinNode) Distinct(field string) *InfluxQLNode

+ func (n *JoinNode) First(field string) *InfluxQLNode

+ func (n *JoinNode) Last(field string) *InfluxQLNode

+ func (n *JoinNode) Log() *LogNode

+ func (n *JoinNode) Max(field string) *InfluxQLNode

+ func (n *JoinNode) Mean(field string) *InfluxQLNode

+ func (n *JoinNode) Median(field string) *InfluxQLNode

+ func (n *JoinNode) Min(field string) *InfluxQLNode

+ func (n *JoinNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *JoinNode) Shift(shift time.Duration) *ShiftNode

+ func (n *JoinNode) Spread(field string) *InfluxQLNode

+ func (n *JoinNode) Stddev(field string) *InfluxQLNode

+ func (n *JoinNode) Sum(field string) *InfluxQLNode

+ func (n *JoinNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ type LogNode struct

+ Level string

+ Prefix string

+ func (n *LogNode) Alert() *AlertNode

+ func (n *LogNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *LogNode) Count(field string) *InfluxQLNode

+ func (n *LogNode) Derivative(field string) *DerivativeNode

+ func (n *LogNode) Distinct(field string) *InfluxQLNode

+ func (n *LogNode) Eval(expressions ...tick.Node) *EvalNode

+ func (n *LogNode) First(field string) *InfluxQLNode

+ func (n *LogNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *LogNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *LogNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *LogNode) Join(others ...Node) *JoinNode

+ func (n *LogNode) Last(field string) *InfluxQLNode

+ func (n *LogNode) Log() *LogNode

+ func (n *LogNode) MapReduce(mr MapReduceInfo) *ReduceNode

+ func (n *LogNode) Max(field string) *InfluxQLNode

+ func (n *LogNode) Mean(field string) *InfluxQLNode

+ func (n *LogNode) Median(field string) *InfluxQLNode

+ func (n *LogNode) Min(field string) *InfluxQLNode

+ func (n *LogNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *LogNode) Sample(rate interface{}) *SampleNode

+ func (n *LogNode) Shift(shift time.Duration) *ShiftNode

+ func (n *LogNode) Spread(field string) *InfluxQLNode

+ func (n *LogNode) Stddev(field string) *InfluxQLNode

+ func (n *LogNode) Sum(field string) *InfluxQLNode

+ func (n *LogNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *LogNode) Union(node ...Node) *UnionNode

+ func (n *LogNode) Where(expression tick.Node) *WhereNode

+ func (n *LogNode) Window() *WindowNode

type MapNode

+ func (n *MapNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *MapNode) Count(field string) *InfluxQLNode

+ func (n *MapNode) Distinct(field string) *InfluxQLNode

+ func (n *MapNode) First(field string) *InfluxQLNode

+ func (n *MapNode) Last(field string) *InfluxQLNode

+ func (n *MapNode) Log() *LogNode

+ func (n *MapNode) Max(field string) *InfluxQLNode

+ func (n *MapNode) Mean(field string) *InfluxQLNode

+ func (n *MapNode) Median(field string) *InfluxQLNode

+ func (n *MapNode) Min(field string) *InfluxQLNode

+ func (n *MapNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *MapNode) Shift(shift time.Duration) *ShiftNode

+ func (n *MapNode) Spread(field string) *InfluxQLNode

+ func (n *MapNode) Stddev(field string) *InfluxQLNode

+ func (n *MapNode) Sum(field string) *InfluxQLNode

+ func (n *MapNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ type NoOpNode struct

+ func (n *NoOpNode) Alert() *AlertNode

+ func (n *NoOpNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *NoOpNode) Count(field string) *InfluxQLNode

+ func (n *NoOpNode) Derivative(field string) *DerivativeNode

+ func (n *NoOpNode) Distinct(field string) *InfluxQLNode

+ func (n *NoOpNode) Eval(expressions ...tick.Node) *EvalNode

+ func (n *NoOpNode) First(field string) *InfluxQLNode

+ func (n *NoOpNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *NoOpNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *NoOpNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *NoOpNode) Join(others ...Node) *JoinNode

+ func (n *NoOpNode) Last(field string) *InfluxQLNode

+ func (n *NoOpNode) Log() *LogNode

+ func (n *NoOpNode) MapReduce(mr MapReduceInfo) *ReduceNode

+ func (n *NoOpNode) Max(field string) *InfluxQLNode

+ func (n *NoOpNode) Mean(field string) *InfluxQLNode

+ func (n *NoOpNode) Median(field string) *InfluxQLNode

+ func (n *NoOpNode) Min(field string) *InfluxQLNode

+ func (n *NoOpNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *NoOpNode) Sample(rate interface{}) *SampleNode

+ func (n *NoOpNode) Shift(shift time.Duration) *ShiftNode

+ func (n *NoOpNode) Spread(field string) *InfluxQLNode

+ func (n *NoOpNode) Stddev(field string) *InfluxQLNode

+ func (n *NoOpNode) Sum(field string) *InfluxQLNode

+ func (n *NoOpNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *NoOpNode) Union(node ...Node) *UnionNode

+ func (n *NoOpNode) Where(expression tick.Node) *WhereNode

+ func (n *NoOpNode) Window() *WindowNode

+ type ReduceCreater struct

+ CreateFloatBulkIntegerReducer func() (FloatBulkPointAggregator, influxql.IntegerPointEmitter)

+ CreateFloatBulkReducer func() (FloatBulkPointAggregator, influxql.FloatPointEmitter)

+ CreateFloatIntegerReducer func() (influxql.FloatPointAggregator, influxql.IntegerPointEmitter)

+ CreateFloatReducer func() (influxql.FloatPointAggregator, influxql.FloatPointEmitter)

+ CreateIntegerBulkFloatReducer func() (IntegerBulkPointAggregator, influxql.FloatPointEmitter)

+ CreateIntegerBulkReducer func() (IntegerBulkPointAggregator, influxql.IntegerPointEmitter)

+ CreateIntegerFloatReducer func() (influxql.IntegerPointAggregator, influxql.FloatPointEmitter)

+ CreateIntegerReducer func() (influxql.IntegerPointAggregator, influxql.IntegerPointEmitter)

+ TopBottomCallInfo *TopBottomCallInfo

type ReduceNode

+ func (n *ReduceNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *ReduceNode) Count(field string) *InfluxQLNode

+ func (n *ReduceNode) Distinct(field string) *InfluxQLNode

+ func (n *ReduceNode) First(field string) *InfluxQLNode

+ func (n *ReduceNode) Last(field string) *InfluxQLNode

+ func (n *ReduceNode) Log() *LogNode

+ func (n *ReduceNode) Max(field string) *InfluxQLNode

+ func (n *ReduceNode) Mean(field string) *InfluxQLNode

+ func (n *ReduceNode) Median(field string) *InfluxQLNode

+ func (n *ReduceNode) Min(field string) *InfluxQLNode

+ func (n *ReduceNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *ReduceNode) Shift(shift time.Duration) *ShiftNode

+ func (n *ReduceNode) Spread(field string) *InfluxQLNode

+ func (n *ReduceNode) Stddev(field string) *InfluxQLNode

+ func (n *ReduceNode) Sum(field string) *InfluxQLNode

+ func (n *ReduceNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

type SampleNode

+ func (n *SampleNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *SampleNode) Distinct(field string) *InfluxQLNode

+ func (n *SampleNode) First(field string) *InfluxQLNode

+ func (n *SampleNode) Last(field string) *InfluxQLNode

+ func (n *SampleNode) Log() *LogNode

+ func (n *SampleNode) Max(field string) *InfluxQLNode

+ func (n *SampleNode) Mean(field string) *InfluxQLNode

+ func (n *SampleNode) Median(field string) *InfluxQLNode

+ func (n *SampleNode) Min(field string) *InfluxQLNode

+ func (n *SampleNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *SampleNode) Shift(shift time.Duration) *ShiftNode

+ func (n *SampleNode) Spread(field string) *InfluxQLNode

+ func (n *SampleNode) Stddev(field string) *InfluxQLNode

+ func (n *SampleNode) Sum(field string) *InfluxQLNode

+ func (n *SampleNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ type ShiftNode struct

+ Shift time.Duration

+ func (n *ShiftNode) Alert() *AlertNode

+ func (n *ShiftNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *ShiftNode) Count(field string) *InfluxQLNode

+ func (n *ShiftNode) Derivative(field string) *DerivativeNode

+ func (n *ShiftNode) Distinct(field string) *InfluxQLNode

+ func (n *ShiftNode) Eval(expressions ...tick.Node) *EvalNode

+ func (n *ShiftNode) First(field string) *InfluxQLNode

+ func (n *ShiftNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *ShiftNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *ShiftNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *ShiftNode) Join(others ...Node) *JoinNode

+ func (n *ShiftNode) Last(field string) *InfluxQLNode

+ func (n *ShiftNode) Log() *LogNode

+ func (n *ShiftNode) MapReduce(mr MapReduceInfo) *ReduceNode

+ func (n *ShiftNode) Max(field string) *InfluxQLNode

+ func (n *ShiftNode) Mean(field string) *InfluxQLNode

+ func (n *ShiftNode) Median(field string) *InfluxQLNode

+ func (n *ShiftNode) Min(field string) *InfluxQLNode

+ func (n *ShiftNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *ShiftNode) Sample(rate interface{}) *SampleNode

+ func (n *ShiftNode) Spread(field string) *InfluxQLNode

+ func (n *ShiftNode) Stddev(field string) *InfluxQLNode

+ func (n *ShiftNode) Sum(field string) *InfluxQLNode

+ func (n *ShiftNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *ShiftNode) Union(node ...Node) *UnionNode

+ func (n *ShiftNode) Where(expression tick.Node) *WhereNode

+ func (n *ShiftNode) Window() *WindowNode

+ type SourceStreamNode struct

+ func (n *SourceStreamNode) Children() []Node

+ func (n *SourceStreamNode) Deadman(threshold float64, interval time.Duration, expr ...tick.Node) *AlertNode

+ func (n *SourceStreamNode) Desc() string

+ func (n *SourceStreamNode) ID() ID

+ func (n *SourceStreamNode) Name() string

+ func (n *SourceStreamNode) Parents() []Node

+ func (n *SourceStreamNode) Provides() EdgeType

+ func (n *SourceStreamNode) SetName(name string)

+ func (n *SourceStreamNode) Stats(interval time.Duration) *StatsNode

+ func (n *SourceStreamNode) Wants() EdgeType

+ func (s *SourceStreamNode) From() *StreamNode

type StatsNode

+ func (n *StatsNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *StatsNode) Count(field string) *InfluxQLNode

+ func (n *StatsNode) Distinct(field string) *InfluxQLNode

+ func (n *StatsNode) First(field string) *InfluxQLNode

+ func (n *StatsNode) Last(field string) *InfluxQLNode

+ func (n *StatsNode) Log() *LogNode

+ func (n *StatsNode) Max(field string) *InfluxQLNode

+ func (n *StatsNode) Mean(field string) *InfluxQLNode

+ func (n *StatsNode) Median(field string) *InfluxQLNode

+ func (n *StatsNode) Min(field string) *InfluxQLNode

+ func (n *StatsNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *StatsNode) Shift(shift time.Duration) *ShiftNode

+ func (n *StatsNode) Spread(field string) *InfluxQLNode

+ func (n *StatsNode) Stddev(field string) *InfluxQLNode

+ func (n *StatsNode) Sum(field string) *InfluxQLNode

+ func (n *StatsNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

type StreamNode

+ func (n *StreamNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *StreamNode) Count(field string) *InfluxQLNode

+ func (n *StreamNode) Distinct(field string) *InfluxQLNode

+ func (n *StreamNode) First(field string) *InfluxQLNode

+ func (n *StreamNode) Last(field string) *InfluxQLNode

+ func (n *StreamNode) Log() *LogNode

+ func (n *StreamNode) Max(field string) *InfluxQLNode

+ func (n *StreamNode) Mean(field string) *InfluxQLNode

+ func (n *StreamNode) Median(field string) *InfluxQLNode

+ func (n *StreamNode) Min(field string) *InfluxQLNode

+ func (n *StreamNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *StreamNode) Shift(shift time.Duration) *ShiftNode

+ func (n *StreamNode) Spread(field string) *InfluxQLNode

+ func (n *StreamNode) Stddev(field string) *InfluxQLNode

+ func (n *StreamNode) Sum(field string) *InfluxQLNode

+ func (n *StreamNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ type TopBottomCallInfo struct

+ FieldsAndTags []string

type UDFNode

+ func (n *UDFNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *UDFNode) Count(field string) *InfluxQLNode

+ func (n *UDFNode) Distinct(field string) *InfluxQLNode

+ func (n *UDFNode) First(field string) *InfluxQLNode

+ func (n *UDFNode) Last(field string) *InfluxQLNode

+ func (n *UDFNode) Log() *LogNode

+ func (n *UDFNode) Max(field string) *InfluxQLNode

+ func (n *UDFNode) Mean(field string) *InfluxQLNode

+ func (n *UDFNode) Median(field string) *InfluxQLNode

+ func (n *UDFNode) Min(field string) *InfluxQLNode

+ func (n *UDFNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *UDFNode) Shift(shift time.Duration) *ShiftNode

+ func (n *UDFNode) Spread(field string) *InfluxQLNode

+ func (n *UDFNode) Stddev(field string) *InfluxQLNode

+ func (n *UDFNode) Sum(field string) *InfluxQLNode

+ func (n *UDFNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

type UnionNode

+ func (n *UnionNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *UnionNode) Count(field string) *InfluxQLNode

+ func (n *UnionNode) Distinct(field string) *InfluxQLNode

+ func (n *UnionNode) First(field string) *InfluxQLNode

+ func (n *UnionNode) Last(field string) *InfluxQLNode

+ func (n *UnionNode) Log() *LogNode

+ func (n *UnionNode) Max(field string) *InfluxQLNode

+ func (n *UnionNode) Mean(field string) *InfluxQLNode

+ func (n *UnionNode) Median(field string) *InfluxQLNode

+ func (n *UnionNode) Min(field string) *InfluxQLNode

+ func (n *UnionNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *UnionNode) Shift(shift time.Duration) *ShiftNode

+ func (n *UnionNode) Spread(field string) *InfluxQLNode

+ func (n *UnionNode) Stddev(field string) *InfluxQLNode

+ func (n *UnionNode) Sum(field string) *InfluxQLNode

+ func (n *UnionNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

type WhereNode

+ func (n *WhereNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *WhereNode) Count(field string) *InfluxQLNode

+ func (n *WhereNode) Distinct(field string) *InfluxQLNode

+ func (n *WhereNode) First(field string) *InfluxQLNode

+ func (n *WhereNode) Last(field string) *InfluxQLNode

+ func (n *WhereNode) Log() *LogNode

+ func (n *WhereNode) Max(field string) *InfluxQLNode

+ func (n *WhereNode) Mean(field string) *InfluxQLNode

+ func (n *WhereNode) Median(field string) *InfluxQLNode

+ func (n *WhereNode) Min(field string) *InfluxQLNode

+ func (n *WhereNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *WhereNode) Shift(shift time.Duration) *ShiftNode

+ func (n *WhereNode) Spread(field string) *InfluxQLNode

+ func (n *WhereNode) Stddev(field string) *InfluxQLNode

+ func (n *WhereNode) Sum(field string) *InfluxQLNode

+ func (n *WhereNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

type WindowNode

+ func (n *WindowNode) Bottom(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

+ func (n *WindowNode) Count(field string) *InfluxQLNode

+ func (n *WindowNode) Distinct(field string) *InfluxQLNode

+ func (n *WindowNode) First(field string) *InfluxQLNode

+ func (n *WindowNode) Last(field string) *InfluxQLNode

+ func (n *WindowNode) Log() *LogNode

+ func (n *WindowNode) Max(field string) *InfluxQLNode

+ func (n *WindowNode) Mean(field string) *InfluxQLNode

+ func (n *WindowNode) Median(field string) *InfluxQLNode

+ func (n *WindowNode) Min(field string) *InfluxQLNode

+ func (n *WindowNode) Percentile(field string, percentile float64) *InfluxQLNode

+ func (n *WindowNode) Shift(shift time.Duration) *ShiftNode

+ func (n *WindowNode) Spread(field string) *InfluxQLNode

+ func (n *WindowNode) Stddev(field string) *InfluxQLNode

+ func (n *WindowNode) Sum(field string) *InfluxQLNode

+ func (n *WindowNode) Top(num int64, field string, fieldsAndTags ...string) *InfluxQLNode

Feb 8, 2016

Changes in this version

type AlertNode

+ Details string

+ TalkHandlers []*TalkHandler

+ func (a *AlertNode) Talk() *TalkHandler

+ type TalkHandler struct

+ func (n TalkHandler) Children() []Node

+ func (n TalkHandler) Deadman(threshold float64, interval time.Duration, expr ...tick.Node) *AlertNode

+ func (n TalkHandler) Desc() string

+ func (n TalkHandler) ID() ID

+ func (n TalkHandler) Name() string

+ func (n TalkHandler) Parents() []Node

+ func (n TalkHandler) Provides() EdgeType

+ func (n TalkHandler) SetName(name string)

+ func (n TalkHandler) Stats(interval time.Duration) *StatsNode

+ func (n TalkHandler) Wants() EdgeType

Jan 26, 2016

Changes in this version

type AlertNode

+ AlertaHandlers []*AlertaHandler

+ SensuHandlers []*SensuHandler

+ func (a *AlertNode) Alerta() *AlertaHandler

+ func (a *AlertNode) Sensu() *SensuHandler

+ func (n *AlertNode) Deadman(threshold float64, interval time.Duration, expr ...tick.Node) *AlertNode

+ func (n *AlertNode) Stats(interval time.Duration) *StatsNode

+ type AlertaHandler struct

+ Environment string

+ Event string

+ Group string

+ Origin string

+ Resource string

+ Token string

+ Value string

+ func (n AlertaHandler) Children() []Node

+ func (n AlertaHandler) Deadman(threshold float64, interval time.Duration, expr ...tick.Node) *AlertNode

+ func (n AlertaHandler) Desc() string

+ func (n AlertaHandler) ID() ID

+ func (n AlertaHandler) Name() string

+ func (n AlertaHandler) Parents() []Node

+ func (n AlertaHandler) Provides() EdgeType

+ func (n AlertaHandler) SetName(name string)

+ func (n AlertaHandler) Stats(interval time.Duration) *StatsNode

+ func (n AlertaHandler) Wants() EdgeType

+ type DeadmanService interface

+ Global func() bool

+ Id func() string

+ Interval func() time.Duration

+ Message func() string

+ Threshold func() float64

type EmailHandler

+ func (n EmailHandler) Deadman(threshold float64, interval time.Duration, expr ...tick.Node) *AlertNode

+ func (n EmailHandler) Stats(interval time.Duration) *StatsNode

type ExecHandler

+ func (n ExecHandler) Deadman(threshold float64, interval time.Duration, expr ...tick.Node) *AlertNode

+ func (n ExecHandler) Stats(interval time.Duration) *StatsNode

type HTTPOutNode

+ func (n *HTTPOutNode) Deadman(threshold float64, interval time.Duration, expr ...tick.Node) *AlertNode

+ func (n *HTTPOutNode) Stats(interval time.Duration) *StatsNode

type HipChatHandler

+ func (n HipChatHandler) Deadman(threshold float64, interval time.Duration, expr ...tick.Node) *AlertNode

+ func (n HipChatHandler) Stats(interval time.Duration) *StatsNode

type InfluxDBOutNode

+ func (n *InfluxDBOutNode) Deadman(threshold float64, interval time.Duration, expr ...tick.Node) *AlertNode

+ func (n *InfluxDBOutNode) Stats(interval time.Duration) *StatsNode

type LogHandler

+ func (n LogHandler) Deadman(threshold float64, interval time.Duration, expr ...tick.Node) *AlertNode

+ func (n LogHandler) Stats(interval time.Duration) *StatsNode

type OpsGenieHandler

+ func (n OpsGenieHandler) Deadman(threshold float64, interval time.Duration, expr ...tick.Node) *AlertNode

+ func (n OpsGenieHandler) Stats(interval time.Duration) *StatsNode

type PagerDutyHandler

+ func (n PagerDutyHandler) Deadman(threshold float64, interval time.Duration, expr ...tick.Node) *AlertNode

+ func (n PagerDutyHandler) Stats(interval time.Duration) *StatsNode

type PostHandler

+ func (n PostHandler) Deadman(threshold float64, interval time.Duration, expr ...tick.Node) *AlertNode

+ func (n PostHandler) Stats(interval time.Duration) *StatsNode

+ type SensuHandler struct

+ func (n SensuHandler) Children() []Node

+ func (n SensuHandler) Deadman(threshold float64, interval time.Duration, expr ...tick.Node) *AlertNode

+ func (n SensuHandler) Desc() string

+ func (n SensuHandler) ID() ID

+ func (n SensuHandler) Name() string

+ func (n SensuHandler) Parents() []Node

+ func (n SensuHandler) Provides() EdgeType

+ func (n SensuHandler) SetName(name string)

+ func (n SensuHandler) Stats(interval time.Duration) *StatsNode

+ func (n SensuHandler) Wants() EdgeType

type SlackHandler

+ func (n SlackHandler) Deadman(threshold float64, interval time.Duration, expr ...tick.Node) *AlertNode

+ func (n SlackHandler) Stats(interval time.Duration) *StatsNode

type SourceBatchNode

+ func (n *SourceBatchNode) Deadman(threshold float64, interval time.Duration, expr ...tick.Node) *AlertNode

+ func (n *SourceBatchNode) Stats(interval time.Duration) *StatsNode

+ type StatsNode struct

+ Interval time.Duration

+ SourceNode Node

+ func (n *StatsNode) Alert() *AlertNode

+ func (n *StatsNode) Derivative(field string) *DerivativeNode

+ func (n *StatsNode) Eval(expressions ...tick.Node) *EvalNode

+ func (n *StatsNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *StatsNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *StatsNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *StatsNode) Join(others ...Node) *JoinNode

+ func (n *StatsNode) MapReduce(mr MapReduceInfo) *ReduceNode

+ func (n *StatsNode) Sample(rate interface{}) *SampleNode

+ func (n *StatsNode) Union(node ...Node) *UnionNode

+ func (n *StatsNode) Where(expression tick.Node) *WhereNode

+ func (n *StatsNode) Window() *WindowNode

+ type UDFNode struct

+ Commander command.Commander

+ Options []*udf.Option

+ Timeout time.Duration

+ func NewUDF(parent Node, name string, commander command.Commander, timeout time.Duration, ...) *UDFNode

+ func (n *UDFNode) Alert() *AlertNode

+ func (n *UDFNode) Derivative(field string) *DerivativeNode

+ func (n *UDFNode) Eval(expressions ...tick.Node) *EvalNode

+ func (n *UDFNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *UDFNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *UDFNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *UDFNode) Join(others ...Node) *JoinNode

+ func (n *UDFNode) MapReduce(mr MapReduceInfo) *ReduceNode

+ func (n *UDFNode) Sample(rate interface{}) *SampleNode

+ func (n *UDFNode) Union(node ...Node) *UnionNode

+ func (n *UDFNode) Where(expression tick.Node) *WhereNode

+ func (n *UDFNode) Window() *WindowNode

+ func (u *UDFNode) CallMethod(name string, args ...interface{}) (interface{}, error)

+ func (u *UDFNode) Desc() string

+ func (u *UDFNode) HasMethod(name string) bool

+ func (u *UDFNode) HasProperty(name string) bool

+ func (u *UDFNode) Property(name string) interface{}

+ func (u *UDFNode) SetProperty(name string, value interface{}) error

type VictorOpsHandler

+ func (n VictorOpsHandler) Deadman(threshold float64, interval time.Duration, expr ...tick.Node) *AlertNode

+ func (n VictorOpsHandler) Stats(interval time.Duration) *StatsNode

Jan 7, 2016

Changes in this version

type AlertNode

+ EmailHandlers []*EmailHandler

+ ExecHandlers []*ExecHandler

+ HipChatHandlers []*HipChatHandler

+ LogHandlers []*LogHandler

+ OpsGenieHandlers []*OpsGenieHandler

+ PagerDutyHandlers []*PagerDutyHandler

+ PostHandlers []*PostHandler

+ SlackHandlers []*SlackHandler

+ VictorOpsHandlers []*VictorOpsHandler

+ func (a *AlertNode) HipChat() *HipChatHandler

+ func (a *AlertNode) OpsGenie() *OpsGenieHandler

+ type EmailHandler struct

+ ToList []string

+ func (n EmailHandler) Children() []Node

+ func (n EmailHandler) Desc() string

+ func (n EmailHandler) ID() ID

+ func (n EmailHandler) Name() string

+ func (n EmailHandler) Parents() []Node

+ func (n EmailHandler) Provides() EdgeType

+ func (n EmailHandler) SetName(name string)

+ func (n EmailHandler) Wants() EdgeType

+ type ExecHandler struct

+ Command []string

+ func (n ExecHandler) Children() []Node

+ func (n ExecHandler) Desc() string

+ func (n ExecHandler) ID() ID

+ func (n ExecHandler) Name() string

+ func (n ExecHandler) Parents() []Node

+ func (n ExecHandler) Provides() EdgeType

+ func (n ExecHandler) SetName(name string)

+ func (n ExecHandler) Wants() EdgeType

+ type HipChatHandler struct

+ Room string

+ Token string

+ func (n HipChatHandler) Children() []Node

+ func (n HipChatHandler) Desc() string

+ func (n HipChatHandler) ID() ID

+ func (n HipChatHandler) Name() string

+ func (n HipChatHandler) Parents() []Node

+ func (n HipChatHandler) Provides() EdgeType

+ func (n HipChatHandler) SetName(name string)

+ func (n HipChatHandler) Wants() EdgeType

+ type LogHandler struct

+ FilePath string

+ func (n LogHandler) Children() []Node

+ func (n LogHandler) Desc() string

+ func (n LogHandler) ID() ID

+ func (n LogHandler) Name() string

+ func (n LogHandler) Parents() []Node

+ func (n LogHandler) Provides() EdgeType

+ func (n LogHandler) SetName(name string)

+ func (n LogHandler) Wants() EdgeType

+ type OpsGenieHandler struct

+ RecipientsList []string

+ TeamsList []string

+ func (n OpsGenieHandler) Children() []Node

+ func (n OpsGenieHandler) Desc() string

+ func (n OpsGenieHandler) ID() ID

+ func (n OpsGenieHandler) Name() string

+ func (n OpsGenieHandler) Parents() []Node

+ func (n OpsGenieHandler) Provides() EdgeType

+ func (n OpsGenieHandler) SetName(name string)

+ func (n OpsGenieHandler) Wants() EdgeType

+ func (og *OpsGenieHandler) Recipients(recipients ...string) *OpsGenieHandler

+ func (og *OpsGenieHandler) Teams(teams ...string) *OpsGenieHandler

+ type PagerDutyHandler struct

+ func (n PagerDutyHandler) Children() []Node

+ func (n PagerDutyHandler) Desc() string

+ func (n PagerDutyHandler) ID() ID

+ func (n PagerDutyHandler) Name() string

+ func (n PagerDutyHandler) Parents() []Node

+ func (n PagerDutyHandler) Provides() EdgeType

+ func (n PagerDutyHandler) SetName(name string)

+ func (n PagerDutyHandler) Wants() EdgeType

+ type PostHandler struct

+ URL string

+ func (n PostHandler) Children() []Node

+ func (n PostHandler) Desc() string

+ func (n PostHandler) ID() ID

+ func (n PostHandler) Name() string

+ func (n PostHandler) Parents() []Node

+ func (n PostHandler) Provides() EdgeType

+ func (n PostHandler) SetName(name string)

+ func (n PostHandler) Wants() EdgeType

+ type SlackHandler struct

+ Channel string

+ func (n SlackHandler) Children() []Node

+ func (n SlackHandler) Desc() string

+ func (n SlackHandler) ID() ID

+ func (n SlackHandler) Name() string

+ func (n SlackHandler) Parents() []Node

+ func (n SlackHandler) Provides() EdgeType

+ func (n SlackHandler) SetName(name string)

+ func (n SlackHandler) Wants() EdgeType

type StreamNode

+ Dimensions []interface{}

+ type VictorOpsHandler struct

+ RoutingKey string

+ func (n VictorOpsHandler) Children() []Node

+ func (n VictorOpsHandler) Desc() string

+ func (n VictorOpsHandler) ID() ID

+ func (n VictorOpsHandler) Name() string

+ func (n VictorOpsHandler) Parents() []Node

+ func (n VictorOpsHandler) Provides() EdgeType

+ func (n VictorOpsHandler) SetName(name string)

+ func (n VictorOpsHandler) Wants() EdgeType

Nov 30, 2015

Changes in this version

+ type AlertNode struct

+ Command []string

+ Crit tick.Node

+ FlapHigh float64

+ FlapLow float64

+ History int

+ Id string

+ Info tick.Node

+ IsStateChangesOnly bool

+ Log string

+ Message string

+ Post string

+ SlackChannel string

+ ToList []string

+ UseEmail bool

+ UseFlapping bool

+ UsePagerDuty bool

+ UseSlack bool

+ UseVictorOps bool

+ VictorOpsRoutingKey string

+ Warn tick.Node

+ func (a *AlertNode) Channel(channel string) *AlertNode

+ func (a *AlertNode) Email(to ...string) *AlertNode

+ func (a *AlertNode) Exec(executable string, args ...string) *AlertNode

+ func (a *AlertNode) Flapping(low, high float64) Node

+ func (a *AlertNode) PagerDuty() *AlertNode

+ func (a *AlertNode) RoutingKey(routingKey string) *AlertNode

+ func (a *AlertNode) Slack() *AlertNode

+ func (a *AlertNode) StateChangesOnly() *AlertNode

+ func (a *AlertNode) VictorOps() *AlertNode

+ func (n *AlertNode) Children() []Node

+ func (n *AlertNode) Desc() string

+ func (n *AlertNode) ID() ID

+ func (n *AlertNode) Name() string

+ func (n *AlertNode) Parents() []Node

+ func (n *AlertNode) Provides() EdgeType

+ func (n *AlertNode) SetName(name string)

+ func (n *AlertNode) Wants() EdgeType

+ type BatchNode struct

+ Cron string

+ Dimensions []interface{}

+ Every time.Duration

+ Fill interface{}

+ Offset time.Duration

+ Period time.Duration

+ QueryStr string

+ func (b *BatchNode) GroupBy(d ...interface{}) *BatchNode

+ func (n *BatchNode) Alert() *AlertNode

+ func (n *BatchNode) Derivative(field string) *DerivativeNode

+ func (n *BatchNode) Eval(expressions ...tick.Node) *EvalNode

+ func (n *BatchNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *BatchNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *BatchNode) Join(others ...Node) *JoinNode

+ func (n *BatchNode) MapReduce(mr MapReduceInfo) *ReduceNode

+ func (n *BatchNode) Sample(rate interface{}) *SampleNode

+ func (n *BatchNode) Union(node ...Node) *UnionNode

+ func (n *BatchNode) Where(expression tick.Node) *WhereNode

+ func (n *BatchNode) Window() *WindowNode

+ type DerivativeNode struct

+ As string

+ Field string

+ NonNegativeFlag bool

+ Unit time.Duration

+ func (d *DerivativeNode) NonNegative() *DerivativeNode

+ func (n *DerivativeNode) Alert() *AlertNode

+ func (n *DerivativeNode) Derivative(field string) *DerivativeNode

+ func (n *DerivativeNode) Eval(expressions ...tick.Node) *EvalNode

+ func (n *DerivativeNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *DerivativeNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *DerivativeNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *DerivativeNode) Join(others ...Node) *JoinNode

+ func (n *DerivativeNode) MapReduce(mr MapReduceInfo) *ReduceNode

+ func (n *DerivativeNode) Sample(rate interface{}) *SampleNode

+ func (n *DerivativeNode) Union(node ...Node) *UnionNode

+ func (n *DerivativeNode) Where(expression tick.Node) *WhereNode

+ func (n *DerivativeNode) Window() *WindowNode

+ type EdgeType int

+ const BatchEdge

+ const NoEdge

+ const ReduceEdge

+ const StreamEdge

+ func (e EdgeType) String() string

+ type EvalNode struct

+ AsList []string

+ Expressions []tick.Node

+ KeepFlag bool

+ KeepList []string

+ func (e *EvalNode) As(names ...string) *EvalNode

+ func (e *EvalNode) Keep(fields ...string) *EvalNode

+ func (n *EvalNode) Alert() *AlertNode

+ func (n *EvalNode) Derivative(field string) *DerivativeNode

+ func (n *EvalNode) Eval(expressions ...tick.Node) *EvalNode

+ func (n *EvalNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *EvalNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *EvalNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *EvalNode) Join(others ...Node) *JoinNode

+ func (n *EvalNode) MapReduce(mr MapReduceInfo) *ReduceNode

+ func (n *EvalNode) Sample(rate interface{}) *SampleNode

+ func (n *EvalNode) Union(node ...Node) *UnionNode

+ func (n *EvalNode) Where(expression tick.Node) *WhereNode

+ func (n *EvalNode) Window() *WindowNode

+ type GroupByNode struct

+ Dimensions []interface{}

+ func (n *GroupByNode) Alert() *AlertNode

+ func (n *GroupByNode) Derivative(field string) *DerivativeNode

+ func (n *GroupByNode) Eval(expressions ...tick.Node) *EvalNode

+ func (n *GroupByNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *GroupByNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *GroupByNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *GroupByNode) Join(others ...Node) *JoinNode

+ func (n *GroupByNode) MapReduce(mr MapReduceInfo) *ReduceNode

+ func (n *GroupByNode) Sample(rate interface{}) *SampleNode

+ func (n *GroupByNode) Union(node ...Node) *UnionNode

+ func (n *GroupByNode) Where(expression tick.Node) *WhereNode

+ func (n *GroupByNode) Window() *WindowNode

+ type HTTPOutNode struct

+ Endpoint string

+ func (n *HTTPOutNode) Children() []Node

+ func (n *HTTPOutNode) Desc() string

+ func (n *HTTPOutNode) ID() ID

+ func (n *HTTPOutNode) Name() string

+ func (n *HTTPOutNode) Parents() []Node

+ func (n *HTTPOutNode) Provides() EdgeType

+ func (n *HTTPOutNode) SetName(name string)

+ func (n *HTTPOutNode) Wants() EdgeType

+ type ID int

+ type InfluxDBOutNode struct

+ Database string

+ Measurement string

+ Precision string

+ RetentionPolicy string

+ Tags map[string]string

+ WriteConsistency string

+ func (i *InfluxDBOutNode) Tag(key, value string) *InfluxDBOutNode

+ func (n *InfluxDBOutNode) Children() []Node

+ func (n *InfluxDBOutNode) Desc() string

+ func (n *InfluxDBOutNode) ID() ID

+ func (n *InfluxDBOutNode) Name() string

+ func (n *InfluxDBOutNode) Parents() []Node

+ func (n *InfluxDBOutNode) Provides() EdgeType

+ func (n *InfluxDBOutNode) SetName(name string)

+ func (n *InfluxDBOutNode) Wants() EdgeType

+ type JoinNode struct

+ Fill interface{}

+ Names []string

+ StreamName string

+ Tolerance time.Duration

+ func (j *JoinNode) As(names ...string) *JoinNode

+ func (n *JoinNode) Alert() *AlertNode

+ func (n *JoinNode) Derivative(field string) *DerivativeNode

+ func (n *JoinNode) Eval(expressions ...tick.Node) *EvalNode

+ func (n *JoinNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *JoinNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *JoinNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *JoinNode) Join(others ...Node) *JoinNode

+ func (n *JoinNode) MapReduce(mr MapReduceInfo) *ReduceNode

+ func (n *JoinNode) Sample(rate interface{}) *SampleNode

+ func (n *JoinNode) Union(node ...Node) *UnionNode

+ func (n *JoinNode) Where(expression tick.Node) *WhereNode

+ func (n *JoinNode) Window() *WindowNode

+ type MapNode struct

+ Map interface{}

+ func (n *MapNode) Alert() *AlertNode

+ func (n *MapNode) Derivative(field string) *DerivativeNode

+ func (n *MapNode) Eval(expressions ...tick.Node) *EvalNode

+ func (n *MapNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *MapNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *MapNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *MapNode) Join(others ...Node) *JoinNode

+ func (n *MapNode) MapReduce(mr MapReduceInfo) *ReduceNode

+ func (n *MapNode) Sample(rate interface{}) *SampleNode

+ func (n *MapNode) Union(node ...Node) *UnionNode

+ func (n *MapNode) Where(expression tick.Node) *WhereNode

+ func (n *MapNode) Window() *WindowNode

+ type MapReduceInfo struct

+ Edge EdgeType

+ Map interface{}

+ Reduce interface{}

+ type Node interface

+ Children func() []Node

+ Desc func() string

+ ID func() ID

+ Name func() string

+ Parents func() []Node

+ Provides func() EdgeType

+ SetName func(string)

+ Wants func() EdgeType

+ type Pipeline struct

+ Source Node

+ func CreatePipeline(script string, sourceEdge EdgeType, scope *tick.Scope) (*Pipeline, error)

+ func (p *Pipeline) Dot(name string) []byte

+ func (p *Pipeline) Walk(f func(n Node) error) error

+ type ReduceNode struct

+ As string

+ PointTimes bool

+ Reduce interface{}

+ func (n *ReduceNode) Alert() *AlertNode

+ func (n *ReduceNode) Derivative(field string) *DerivativeNode

+ func (n *ReduceNode) Eval(expressions ...tick.Node) *EvalNode

+ func (n *ReduceNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *ReduceNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *ReduceNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *ReduceNode) Join(others ...Node) *JoinNode

+ func (n *ReduceNode) MapReduce(mr MapReduceInfo) *ReduceNode

+ func (n *ReduceNode) Sample(rate interface{}) *SampleNode

+ func (n *ReduceNode) Union(node ...Node) *UnionNode

+ func (n *ReduceNode) Where(expression tick.Node) *WhereNode

+ func (n *ReduceNode) Window() *WindowNode

+ func (r *ReduceNode) UsePointTimes() *ReduceNode

+ type SampleNode struct

+ Count int64

+ Duration time.Duration

+ func (n *SampleNode) Alert() *AlertNode

+ func (n *SampleNode) Derivative(field string) *DerivativeNode

+ func (n *SampleNode) Eval(expressions ...tick.Node) *EvalNode

+ func (n *SampleNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *SampleNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *SampleNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *SampleNode) Join(others ...Node) *JoinNode

+ func (n *SampleNode) MapReduce(mr MapReduceInfo) *ReduceNode

+ func (n *SampleNode) Sample(rate interface{}) *SampleNode

+ func (n *SampleNode) Union(node ...Node) *UnionNode

+ func (n *SampleNode) Where(expression tick.Node) *WhereNode

+ func (n *SampleNode) Window() *WindowNode

+ type SourceBatchNode struct

+ func (b *SourceBatchNode) Query(q string) *BatchNode

+ func (n *SourceBatchNode) Children() []Node

+ func (n *SourceBatchNode) Desc() string

+ func (n *SourceBatchNode) ID() ID

+ func (n *SourceBatchNode) Name() string

+ func (n *SourceBatchNode) Parents() []Node

+ func (n *SourceBatchNode) Provides() EdgeType

+ func (n *SourceBatchNode) SetName(name string)

+ func (n *SourceBatchNode) Wants() EdgeType

+ type StreamNode struct

+ Database string

+ Expression tick.Node

+ Measurement string

+ RetentionPolicy string

+ Truncate time.Duration

+ func (n *StreamNode) Alert() *AlertNode

+ func (n *StreamNode) Derivative(field string) *DerivativeNode

+ func (n *StreamNode) Eval(expressions ...tick.Node) *EvalNode

+ func (n *StreamNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *StreamNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *StreamNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *StreamNode) Join(others ...Node) *JoinNode

+ func (n *StreamNode) MapReduce(mr MapReduceInfo) *ReduceNode

+ func (n *StreamNode) Sample(rate interface{}) *SampleNode

+ func (n *StreamNode) Union(node ...Node) *UnionNode

+ func (n *StreamNode) Window() *WindowNode

+ func (s *StreamNode) From() *StreamNode

+ func (s *StreamNode) Where(expression tick.Node) *StreamNode

+ type UnionNode struct

+ Rename string

+ func (n *UnionNode) Alert() *AlertNode

+ func (n *UnionNode) Derivative(field string) *DerivativeNode

+ func (n *UnionNode) Eval(expressions ...tick.Node) *EvalNode

+ func (n *UnionNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *UnionNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *UnionNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *UnionNode) Join(others ...Node) *JoinNode

+ func (n *UnionNode) MapReduce(mr MapReduceInfo) *ReduceNode

+ func (n *UnionNode) Sample(rate interface{}) *SampleNode

+ func (n *UnionNode) Union(node ...Node) *UnionNode

+ func (n *UnionNode) Where(expression tick.Node) *WhereNode

+ func (n *UnionNode) Window() *WindowNode

+ type WhereNode struct

+ Expression tick.Node

+ func (n *WhereNode) Alert() *AlertNode

+ func (n *WhereNode) Derivative(field string) *DerivativeNode

+ func (n *WhereNode) Eval(expressions ...tick.Node) *EvalNode

+ func (n *WhereNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *WhereNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *WhereNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *WhereNode) Join(others ...Node) *JoinNode

+ func (n *WhereNode) MapReduce(mr MapReduceInfo) *ReduceNode

+ func (n *WhereNode) Sample(rate interface{}) *SampleNode

+ func (n *WhereNode) Union(node ...Node) *UnionNode

+ func (n *WhereNode) Where(expression tick.Node) *WhereNode

+ func (n *WhereNode) Window() *WindowNode

+ type WindowNode struct

+ AlignFlag bool

+ Every time.Duration

+ Period time.Duration

+ func (n *WindowNode) Alert() *AlertNode

+ func (n *WindowNode) Derivative(field string) *DerivativeNode

+ func (n *WindowNode) Eval(expressions ...tick.Node) *EvalNode

+ func (n *WindowNode) GroupBy(tag ...interface{}) *GroupByNode

+ func (n *WindowNode) HttpOut(endpoint string) *HTTPOutNode

+ func (n *WindowNode) InfluxDBOut() *InfluxDBOutNode

+ func (n *WindowNode) Join(others ...Node) *JoinNode

+ func (n *WindowNode) MapReduce(mr MapReduceInfo) *ReduceNode

+ func (n *WindowNode) Sample(rate interface{}) *SampleNode

+ func (n *WindowNode) Union(node ...Node) *UnionNode

+ func (n *WindowNode) Where(expression tick.Node) *WhereNode

+ func (n *WindowNode) Window() *WindowNode

+ func (w *WindowNode) Align() *WindowNode