Concurrency specifies the desired concurrency of a Stage or Producer.

Do runs the parallel pipeline defined by the specified Producer and Stages.

InputBufferSize defines the size of the input buffer of a Stage.

Measure behaves like Do(), running the parallel pipeline defined by the specified Producer and Stages, but also measures the time spent in each stage.

Name specifies the name of a Stage or a Producer, for debugging.

NewProducer defines an initial stage in a pipeline, in which work items of type T are prepared for processing.

NewRecyclingProducer defines an initial stage in a pipeline, in which work items of type T are prepared for processing.

NewStage defines an intermediate stage in a pipeline, in which work items of type T are operated upon.

SequentialDo behaves like Do(), but runs sequentially on one thread.

Metrics defines a set of performance metrics collected for an entire pipeline.

StageMetrics defines a set of performance metrics collected for a particular pipeline stage.

Producer defines a function building a pipeline producer.

Stage defines a function building a pipeline stage.