Package drawer provides a way to draw a pipeline graph.

Package measure provides a way to measure the performance of a pipeline.

AddMerger adds a merger step to the pipeline.

AddRootStep adds a root step to the pipeline.

AddSink adds a sink step to the pipeline.

AddSinkFromChan adds a sink step to the pipeline.

AddSplitter adds a splitter step to the pipeline.

AddSplitterFn adds a splitter step to the pipeline.

AddStepFromChan adds a step that takes an input channel and produces an output channel.

AddStepOneToMany adds a step that takes one input and produces many outputs.

AddStepOneToOne adds a step that takes one input and produces one output.

AddStepOneToOneOrZero adds a step that takes one input and produces one output.

New creates a new pipeline.

SplitterBufferSize sets the buffer size of the Splitter.

StepConcurrency sets the concurrency of the step.

StepKeepOpen does not close input channel.

ErrInputMustBeSet is returned when the input is not set.

ErrPipelineMustBeSet is returned when the pipeline is not set.

ErrSplitterTotal is returned when the total is not set.

Pipeline is a pipeline of steps.

Splitter is a step that splits the input into multiple outputs.

OneToManyFn is a function that takes an input and produces many outputs.

OneToOneFn is a function that takes an input and produces an output.

SplitterFn is a function that returns wether to keep the input or not.

SplitterOption is a function that modifies a Splitter.

StepFromChanFn is a function that takes an input channel and produces an output channel.

StepOption is a function that modifies a Step.