ratchet

Mar 3, 2016

Changes in this version

+ var StartSignal = "GO"

+ func Do(processor DataProcessor) *dataProcessor

+ type ConcurrentDataProcessor interface

+ Concurrency func() int

+ type DataProcessor interface

+ Finish func(outputChan chan data.JSON, killChan chan error)

+ ProcessData func(d data.JSON, outputChan chan data.JSON, killChan chan error)

+ type Pipeline struct

+ BufferLength int

+ Name string

+ PrintData bool

+ func NewBranchingPipeline(layout *PipelineLayout) *Pipeline

+ func NewPipeline(processors ...DataProcessor) *Pipeline

+ func (p *Pipeline) Run() (killChan chan error)

+ func (p *Pipeline) Stats() string

+ type PipelineLayout struct

+ func NewPipelineLayout(stages ...*PipelineStage) (*PipelineLayout, error)

+ type PipelineStage struct

+ func NewPipelineStage(processors ...*dataProcessor) *PipelineStage