Versions in this module Expand all Collapse all v3 v3.0.1 Dec 9, 2020 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 PipelineIface interface + Run func() chan error + type PipelineLayout struct + func NewPipelineLayout(stages ...*PipelineStage) (*PipelineLayout, error) + type PipelineStage struct + func NewPipelineStage(processors ...*dataProcessor) *PipelineStage Other modules containing this package github.com/indosatppi/ratchet