pipeline

package

Go to main page

Versions in this module

v0

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