pipeline

package

Go to main page

Versions in this module

v1

v1.0.0-beta2

Jun 17, 2016

v1.0.0-beta1

Jun 6, 2016

v0

v0.13.1

May 13, 2016

v0.13.0

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

v0.13.0-rc3

May 10, 2016

v0.13.0-rc2

May 7, 2016

v0.13.0-rc1

May 5, 2016

v0.12.0

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

v0.12.0-rc2

Apr 1, 2016

v0.12.0-rc1

Mar 29, 2016

v0.11.0

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

v0.11.0-rc3

Mar 21, 2016

v0.11.0-rc2

Mar 17, 2016

v0.11.0-rc1

Mar 14, 2016

v0.10.1

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

v0.10.0

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

v0.10.0-rc2

Jan 22, 2016

v0.10.0-rc1

Jan 20, 2016

v0.2.4

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

v0.2.3

Dec 22, 2015

v0.2.2

Dec 15, 2015

v0.2.1

Dec 14, 2015

v0.2.0

Dec 7, 2015

v0.1.2

Dec 2, 2015

v0.1.1

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

v0.1.1-rc1

Nov 25, 2015

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL