Versions in this module Expand all Collapse all v1 v1.0.0 Sep 26, 2021 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
Go to main page