kapacitor internals

pipeline.node

+ parents:[]Node+ children:[]Node- wants:EdgeType- provides:EdgeType

impl

edge.consumer

+ edge:edge.Edge+ r:edge.Receiver

- Consume()

edge.channelEdge

+ messages: chan Message

edge.StatsEdge

- Collect()- Emit()- Close()- Abort()- Type()

inherit

Task

+ ID:string+ pipeline:*pipeline.Pipeline+ Type:TaskType+ DBRPs:[]DBRP

+ Dot()

contains

edge.statsEdge

+ Collected()+ Emitted()

edge.Receiver

- BeginBatch()- BatchPoint()- EndBatch()- Point()- Barrier()- DeleteGroup()

ExecutingTask

+ tm:*TaskMaster+ task:*Task+ source:Node+ outputs:map[string]Output+ nodes:[]Node

+ walk()+ link()+ start()+ stop()+ createNode()+ Snapshot()

edge.Consumer

pipeline.Node

+ Parents():[]Node+ Children():[]Node- linkChild()- addParent()

Node

- init()- addParentEdge()- start()- stop()

edge.Edge

node

+ parents:[]Node+ children:[]Node+ ins:[]edge.StatsEdge+ outs:[]edge.StatsEdge+ et:ExecutingTask

- runF()- stopF()

pipeline.Pipeline

+ sources:[]Node+ sorted:[]Node

+ Walk()+ sort()