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()
