Discover Packages
github.com/bongnv/pipeline
package
module
Version:
v0.0.0-...-d8978e9
Opens a new window with list of versions in this module.
Published: May 11, 2023
License: MIT
Opens a new window with license information.
Imports: 2
Opens a new window with list of imports.
Imported by: 0
Opens a new window with list of known importers.
README
README
¶
pipeline
A simple Go pipeline
Expand ▾
Collapse ▴
Documentation
¶
Do runs the pipeline specified by the source and stages.
Source will produce work items and each stage will process them.
NewSource creates a new source stage to procude work items.
They then be processed by each stage.
SourceFn is a function to produce work items.
It should call put(item) to add an item into the pipeline for processing.
NewStage creates a new stage to process work items.
StageFn is a function process a work item.
It takes an item as an input an return a new one after processing.
The last stage is a sink stage and its output will be ignored.
Source Files
¶
Click to show internal directories.
Click to hide internal directories.